无法使用 Elasticsearch Watcher 正确转换 {{ctx.payload.hits.hits}}

Question

我的watcher配置如下：

{
  "trigger": {
    "schedule": {
      "interval": "5s"
    }
  },
  "input" : {
    "search" : {
      "request" : {
        "indices" : [ "my_index" ],
        "types" : [ "my_type" ],
        "body" : {
          "query" : {
            "match_all" : {}
           }
        }
      }
    }
  },
  "transform" : {
      "script" : "return [ body: groovy.json.JsonOutput.toJson(ctx.payload.hits.hits)]"
  },
  "actions" : {
    "hbase_webhook" : {
        "webhook" : {
            "method" : "POST",
            "host" : "<some_ip>",
            "port" : <some_port>,
            "path": "/v0.1/_events",
            "body" : "data: {{ctx.payload.body}}"
        }
    }
  }
}

正文中发布的数据无效JSON：类似于：

{ 'data: ': { '{"_index":"my_index","_type":"my_type","_source":{"key":"val"}},"_id":"<some_id>","_score":1.0}': '' } }

我不知道如何解析此输出，因为 Node.js 中的 JSON.parse 无论如何都无法正确解析它。

Answer 1

从来没有。忘记。 Headers.

我忘记了：

"headers" {
    "Content-type": "application/json"
}

所以用任何工具都无法解析。

Answer 2

运行在为我们只想发送符合特定条件的实际记录的端点创建警报时加入其中。请参阅下面的示例：

"actions": {
    "my_webhook": {
      "webhook": {
        "scheme": "https",
        "host": "webhook.site",
        "port": 443,
        "method": "post",
        "path": "/webhooksiteguidwouldbehere",
        "params": {},
        "headers": {
          "Content-type": "application/json"
        },
        "body": "{{#toJson}}ctx.payload.hits.hits{{/toJson}}"
      }
    }
  }

第二个注意事项：如果正文大小设置为 0，则您的命中将返回为 null。 :)

无法使用 Elasticsearch Watcher 正确转换 {{ctx.payload.hits.hits}}

Cannot Transform Correctly with Elasticsearch Watcher {{ctx.payload.hits.hits}}

json

elasticsearch

elasticsearch-plugin

elasticsearch-watcher