golang elasticSearch upsert 单条数据(使用包 olivere/elastic)

Golang · Fecmall · 于 6年前 发布 · 2116 次阅读

golang 和elastic的连接,使用了包:https://github.com/olivere/elastic

func UpsertType(esIndexName string, esTypeName string, idStr string, bodyJson interface{}) error{
    var err error
    ctx := context.Background()
    client, err := Client()
    upsertResult, err := client.Index().
		Index(esIndexName).
		Type(esTypeName).
		Id(idStr).
		BodyJson(bodyJson).
		Do(ctx)
	if err != nil {
		return err
	}
	log.Printf("Indexed tweet %s to index %s, type %s\n", upsertResult.Id, upsertResult.Index, upsertResult.Type)
    return err
}
共收到 0 条回复
没有找到数据。
添加回复 (需要登录)
需要 登录 后方可回复, 如果你还没有账号请点击这里 注册
Your Site Analytics