ElasticSearch批量插入数据
最后更新:2025-07-24 11:08:52
|
状态:未完成
|
相关数据库:
ElasticSearch-Elasticsearch
/*
PUT index_user/_bulk
{"index":{"_index":"index_user"}}
{"id":1001, "name":"a b", "age":20}
{"index":{"_index":"index_user", "_id":"10012"}}
{"id":1002, "name":"b c", "age":20}
{"index":{"_index":"index_user", "_id":"10013"}}
{"id":1003, "name":"c d", "age":30}*/
DataSet set = new DataSet();
Long fr = System.currentTimeMillis();
for(int i=0; i<10; i++){
DataRow row = new ElasticSearchRow();
row.put("CODE", "C"+i);
row.put("NAME", "N"+i);
if(i%3 == 0){
row.put("_id", fr+i);
row.setTable(table_name + "_tmp");
}
set.add(row);
}
ServiceProxy.insert(table_name, set);