go语言esUpdateByQuery_go update es

在Go语言中使用Elasticsearch的`updateByQuery`功能，可以通过`elastic/go-elasticsearch`库来实现。`updateByQuery` API用于更新匹配指定查询的文档。如果没有指定查询，则对索引中的每个文档执行更新操作，这在例如需要让所有文档应用新的映射（mapping）更改时非常有用。

以下是使用`updateByQuery`的基本步骤和示例代码：

1. **初始化Elasticsearch客户端**：
   首先，需要创建并配置一个Elasticsearch客户端实例，用于与Elasticsearch集群进行通信。

   ```go
   esUrl := "http://127.0.0.1:9200"
   ctx := context.Background()
   client, err := elastic.NewClient(elastic.SetURL(esUrl))
   if err != nil {
       log.Fatalf("Error creating the client: %s", err)
   }
   ```

2. **构建查询**：
   使用`elastic.NewBoolQuery()`、`elastic.NewTermQuery()`、`elastic.NewRangeQuery()`等函数构建你的查询条件。

   ```go
   query := elastic.NewBoolQuery().
       Filter(elastic.NewTermQuery("field_name", "value"))
   ```

3. **构建更新脚本**：
   使用`elastic.NewScript()`创建一个更新脚本，该脚本定义了如何更新匹配的文档。

   ```go
   script := elastic.NewScriptInline(`ctx._source.new_field = 'new_value'`).
       Params(map[string]interface{}{
           "new_value": "value_to_set",
       })
   ```

4. **执行`updateByQuery`操作**：
   使用客户端的`UpdateByQuery`方法执行更新操作，并传入索引名称、查询和更新脚本。

   ```go
   resp, err := client.UpdateByQuery(ctx).
       Index("index_name").
       Query(query).
       Script(script).
       Refresh("true").
       Do(ctx)
   if err != nil {
       log.Fatalf("Error updating by query: %s", err)
   }
   defer resp.Body.Close()
   ```

5. **处理响应**：
   检查响应以确定操作是否成功，并获取更新的文档数量等信息。

   ```go
   if resp.StatusCode == http.StatusOK {
       fmt.Printf("Updated %d documents\n", resp.Updated)
   } else {
       fmt.Printf("Error: %s\n", resp.String())
   }
   ```

请注意，上述代码仅为示例，实际使用时需要根据你的Elasticsearch版本和具体需求进行调整。同时，确保你的Elasticsearch集群可访问，并且Go环境已经安装了`elastic/go-elasticsearch`库。