jjzjj

BulkIndexer

全部标签

elasticsearch - 用于 Golang 的 Olivere 包中的 BulkIndexer 用于替换 Elastigo

我注意到,如果我想将数据批量发送到elasticsearch,我可以使用BulkIndexer。如Elastigo文档中所述Abulkindexercreatesgoroutines,andchannelsforconnectingandsendingdatatoelasticsearchinbulk,usingbuffers.elastigo中的代码以批量插入varc_es=elastigo.NewConn()varindexer=c_es.NewBulkIndexer(50)funcinsertInBulkElastic(){//Createacustomerrorfunction