bulk Java提交数据,Elasticsearch 之（47） Java API 基于bulk实现多4S店销售数据批量上传...

深碍√TFBOYSˉ_ 2023-01-15 02:27 4阅读 0赞

PUT /car\_shop/sales/1

\{

"brand": "宝马",

"name": "宝马320",

"price": 320000,

"produce\_date": "2017-01-01",

"sale\_price": 300000,

"sale\_date": "2017-01-21"

\}

PUT /car\_shop/sales/2

\{

"brand": "宝马",

"name": "宝马320",

"price": 320000,

"produce\_date": "2017-01-01",

"sale\_price": 300000,

"sale\_date": "2017-01-21"

\}

package com.es.app;

import org.elasticsearch.action.bulk.BulkItemResponse;

import org.elasticsearch.action.bulk.BulkRequestBuilder;

import org.elasticsearch.action.bulk.BulkResponse;

import org.elasticsearch.action.delete.DeleteRequestBuilder;

import org.elasticsearch.action.index.IndexRequest;

import org.elasticsearch.action.index.IndexRequestBuilder;

import org.elasticsearch.action.update.UpdateRequest;

import org.elasticsearch.action.update.UpdateRequestBuilder;

import org.elasticsearch.action.update.UpdateResponse;

import org.elasticsearch.client.transport.TransportClient;

import org.elasticsearch.common.settings.Settings;

import org.elasticsearch.common.transport.InetSocketTransportAddress;

import org.elasticsearch.common.xcontent.XContentFactory;

import org.elasticsearch.transport.client.PreBuiltTransportClient;

import java.net.InetAddress;

public class BulkCarInfoApp \{

public static void main(String\[\] args) throws Exception\{

Settings settings = Settings.builder()

.put("cluster.name", "elasticsearch")

.put("client.transport.sniff", true)

.build();

TransportClient client = new PreBuiltTransportClient(settings)

.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));

BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();

IndexRequestBuilder indexRequestBuilder = client.prepareIndex("car\_shop", "sales", "3")

.setSource(XContentFactory.jsonBuilder()

.startObject()

.field("brand", "奔驰")

.field("name", "奔驰C200")

.field("price", 350000)

.field("produce\_date", "2017-01-20")

.field("sale\_price", 320000)

.field("sale\_date", "2017-01-25")

.endObject());

bulkRequestBuilder.add(indexRequestBuilder);

UpdateRequestBuilder updateRequestBuilder = client.prepareUpdate("car\_shop", "sales", "1")

.setDoc(XContentFactory.jsonBuilder()

.startObject()

.field("sale\_price", 290000)

.endObject());

bulkRequestBuilder.add(updateRequestBuilder);

DeleteRequestBuilder deleteRequestBuilder = client.prepareDelete("car\_shop", "sales", "2");

bulkRequestBuilder.add(deleteRequestBuilder);

BulkResponse bulkResponse = bulkRequestBuilder.get();

for(BulkItemResponse bulkItemResponse : bulkResponse.getItems()) \{

System.out.println("version: " + bulkItemResponse.getVersion());

\}

client.close();

\}

\}

发表评论取消回复

表情：

评论列表（有 0 条评论，4人围观）

还没有评论，来说两句吧...

相关阅读

相关 java操作elasticsearch实现批量添加数据（bulk）

java操作[elasticsearch][]实现批量添加主要使用了bulk 代码如下： //bulk批量操作(批量添加) @Test

悠悠/ 2024年03月24日 14:34/ 0 赞/ 66 阅读

相关 elasticsearch的bulk(批量)操作

在es中我们可能会有这么一种需求，即有时需要批量向es中插入或更新或删除数据，如果一条一条数据的操作，那么速度必然很慢，那么es的bulk api就可以派上用场。 delet

水深无声/ 2024年02月19日 18:36/ 0 赞/ 74 阅读

相关 elasticsearch使用Bulk API实现批量操作

使用bulk api实现批量操作 bulk的格式 {action:{metadata}}\n {requestbody}\n action:(行

布满荆棘的人生/ 2023年06月29日 06:57/ 0 赞/ 25 阅读

相关 bulk Java提交数据,Elasticsearch 之（47） Java API 基于bulk实现多4S店销售数据批量上传...

PUT /car\_shop/sales/1 \{ "brand": "宝马", "name": "宝马320", "price": 320000, "produce

深碍√TFBOYSˉ_/ 2023年01月15日 02:27/ 0 赞/ 5 阅读

相关 ElasticSearch的批量操作bulk

批量插入数据 1. 同一个index下，不指定\_id POST /gunsIndex/doc/_bulk {"index":{}} {"ag

女爷i/ 2022年12月29日 00:24/ 0 赞/ 190 阅读

相关 ES 批量插入数据 bulk

引入依赖 <dependency> <groupId>org.elasticsearch.client</groupId>

深碍√TFBOYSˉ_/ 2022年09月04日 11:48/ 0 赞/ 341 阅读

相关 php使用Elasticsearch之批量操作（bulk）

Elasticsearch的批量操作就像 mget 允许我们一次性检索多个文档一样， bulk API允许我们使用单一请求来实现多个文档的 create 、 index 、 u

左手的ㄟ右手/ 2022年07月03日 16:59/ 0 赞/ 455 阅读

相关 elasticsearch bulk批量增删改

一、bulk的操作类型 delete：删除一个文档，只要1个json串就可以了，其他都需要两个json串 { "delete": { "_index":"tes

朴灿烈づ我的快乐病毒、/ 2022年05月23日 10:28/ 0 赞/ 243 阅读

相关 es 之批量处理 bulk api

简介说明：The bulk API makes it possible to perform many index/delete operations in a

忘是亡心i/ 2022年04月23日 08:52/ 0 赞/ 464 阅读

相关 ElasticSearch bulk批量插入数据

环境：使用RestHighLevelClient进行bulk操作代码如下： / es 批量存数据的方法 1.创建es cl

古城微笑少年丶/ 2022年04月11日 13:47/ 0 赞/ 580 阅读