elasticsearch - 如何在 Golang 中使用 Olivere 将数据插入 Elasticsearch
问题描述
我需要一个正确的例子,我可以在 golang 中使用 Olivere 将数据插入到 elasticsearch 中。我已经收集了数据,它会打印将要插入的每个数据的结果。问题是没有数据插入到elasticsearch中。
这是收集将插入到 elasticsearch 中的数据的代码。
indexing := company
indextype := employee
data := lists{Id: id__,
Article_id: id_row,
Category_id: category_id,
Datee: date,
Media_id: media,
Mention_times: mention,
Data_input_date: data_input_date,
User: user,
name: pc_name}
//Save to Elastic using olivere
response := elastic.NewBulkIndexRequest().Index(indexing).Type(indextype).Id(id__).Doc(data)
if response != nil {
fmt.Println("Print the result", OlivereResponse)
}
/* log the result
Print the result for inserting to elastic using olivere {"index":
{"_index":"company","_id":"2660e1","_type":"employee"}}
{"id":"26688","article_id":20,"category_id":"farming","datee":"2018-11-23","media_id":8, Mention_times: "20", "data_input_date":"2018-12-01 15:42:22","usere":"robot-kwd41","pc_name":"server"}
*/
if OlivereResponse == nil {
fmt.Println("Response returns null when inserting to elasticsearch using
olivere")
}
谁能提供一个完整的示例,如何使用 golang 中的 Olivere 包将数据插入到 elasticsearch 中?
谢谢 }
解决方案
要将数据插入 Elastic 我正在使用这样的代码:
func (e *Elastic) SaveDocument(index string, id string, data interface{}) error {
_, err := e.client.Index().Index(index).Type("entity").Id(id).
BodyJson(data).Refresh("true").Do(e.ctx)
if err != nil {
e.fileLogger.Log(data)
fmt.Printf("Error save document to elastic search: %s. Save log to file\n", err.Error())
}
return err
}
以下是:
- e.client 是 f *elastic.Client 的一个实例;
- e.ctx 是一个上下文。上下文
推荐阅读
- protocol-buffers - C++ protobuf 使用的内存比保存消息所需的内存多得多
- ios - 改进两个数组 Swift 的比较
- javascript - 来自 zone.js 的 Angular 6 未捕获异常
- sql - sql:从 jsonb 列中获取不同的值
- neo4j - loadAll 不加载具有不同标签的关系节点
- sql - SQL左连接多列
- haskell - '.' 和有什么区别?和 '<<<' 执行功能组合时?
- android - Android studio - 在 string.xml 中获取数组字符串项的翻译
- ios - Swift 4:从 Firebase 存储中获取图像并将它们显示在表格视图中
- microsoft-graph-api - Graph API 无法在手机中进行身份验证