我必须将其转换为一个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"
}
}
}
}
任何帮助都是感激的。
1条答案
按热度按时间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有效载荷:
1.运行NiFi流,数据应该被索引到Elasticsearch中。