Elasticsearch HTTP调用方法

xmjla07d  于 2023-03-22  发布在  ElasticSearch
关注(0)|答案(1)|浏览(135)

我必须将其转换为一个http调用方法,以便在Nifi中使用,将数据索引到elasticsearch中。
我的elastcisearch url:http://localhost:9200/elastcsearch
POST /doc1/_update_by_query

{
  "query": {
    "term": {
      "state_num": 4
    }
  },
  "script": {
    "inline": "ctx.\_source.documents.add(params.text)",
    "params": {
      "text": {
        "number": "1",
        "docs_content": "this text goes here"
      }
    }
  }
}

任何帮助都是感激的。

ryevplcw

ryevplcw1#

您可以尝试以下方法

1.在NiFi中创建Invoke HTTP处理器。
1.将HTTP方法属性设置为POST。
1.将“远程URL”属性设置为http://localhost:9200/doc 1/_update_by_query。
1.将Content-Type属性设置为application/json
1.在请求的主体中,包含原始请求的JSON有效载荷:

  • {“query”:{“term”:{“state_num”:4 } },“脚本”:{“inline”:“ctx._source.documents.add(params.text)",“params”:{“text”:{“number”:“1”,“docs_content”:“此文本放在此处”} }}

1.运行NiFi流,数据应该被索引到Elasticsearch中。

相关问题