は、次のように私はウォッチャーの構成を有しているElasticsearchウォッチャー{{}} ctx.payload.hits.hits

Question

と正しく変換できません：

{ 
    "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ではありません：何かのように：

Node.jsのJSON.parseが正しく解析されないため、この出力を解析する方法がわかりません。

Answer 1

忘れる。ヘッダー。

私は忘れました：

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

は、だから、どんなツールを使って解析することができませんでした。