Doris使用Stream Load 导入数据

 curl --location-trusted -u root  -H "label:12345" -H "format: json" -H "Expect:100-continue" -H "read_json_by_line:true" -T test.json http://ip:8030/api/demo/t_history_data_2/_stream_load

Response Headers:  null=[HTTP/1.1 307 Temporary RedirectVary=[Access-Control-Request-Headers, Access-Control-Request-Method, Origin] Content-Length=[0]
    Content-Language=[zh-CN]
    Date=[Tue, 06 Feb 2024 08:41:22 GMT]
    Location=[http://root%40default_cluster:@ip:8040/api/demo/t_history_data_2/_stream_load/?]
Response Body: 

String jsonData = data.stream()
        .map(JSONObject::toJSONString)
        .collect(Collectors.joining("\n"));

// 构建批量提交的URL
String batchUrl = DORIS_BASE_URL + "/" + DORIS_DATABASE + "/" + DORIS_TABLE + "/_stream_load/";
HttpRequest request = HttpUtil.createRequest(Method.PUT, batchUrl);
request.header(HttpHeaders.AUTHORIZATION,  getBasicAuthHeader(DORIS_USERNAME, DORIS_PASSWORD));
request.header("label", UUID.randomUUID().toString());
request.header("format", "json");
request.header("Expect", "100-continue");
// 读行
request.header("read_json_by_line","true");

// 获取实际BE结点地址
HttpResponse execute = request.execute();
String header = execute.header(HttpHeaders.LOCATION);
if (!header.isEmpty()){
    request.body(jsonData);
    batchUrl = header;
    request.setUrl(batchUrl);
    HttpResponse insertResponse = request.execute();
    System.out.println(insertResponse);
}