InvokeHTTPにPOSTクエリの特定の値を代入する方法は？

Question

私は、プロセッサの以下の配列を有する：

私はReplaceTextプロセッサを使用してPOSTクエリーのボディを作成します。このプロセッサはInvokeHTTPにリンクされています。 ReplaceTextで置換値は次のとおり

{ 
    "size": 0, 
    "query": { 
    "bool": { 
     "filter": [ 
     {"term": {"Field1": ""}}, 
     {"term": {"Field2": ""}}, 
     {"term": {"Field3": ""}}, 
     {"term": {"Field4": ""}} 
     ] 
    } 
    }, 
    "aggs": { 
    "range": { 
     "date_range": { 
      "field": "Datetime", 
      "ranges": [ 
       { 
        "from": "2017-02-17T16:00:00Z||-1H/H", 
        "to": "2017-02-17T16:00:00Z||/H" 
       } 
      ] 
     } 
    } 
    } 
} 

InvokeHTTP

でクエリを実行する前に、私は（入力FlowFileの実際のフィールドの値に応じField1、Field2、Field3とField4の値を交換する必要がありますUpdateAttributeの出力）。クエリField1ではなく空の文字列のABCに等しくなければならない私のPOSTでのよう

例えば、入力FlowFileに私は、ABCに等しいField1持っています。

これを行うにはどうすればよいですか？

Answer 1

ReplaceTextにNiFi Expression Languageを使用できます。あなたは4つの属性がfield.4スルーfield.1持っていると仮定すると、あなたは次のようにテキスト全体を置き換えることができます。

{ 
    "size": 0, 
    "query": { 
    "bool": { 
     "filter": [ 
     {"term": {"Field1": "${field.1}"}}, 
     {"term": {"Field2": "${field.2}"}}, 
     {"term": {"Field3": "${field.3}"}}, 
     {"term": {"Field4": "${field.4}"}} 
     ] 
    } 
    }, 
    "aggs": { 
    "range": { 
     "date_range": { 
      "field": "Datetime", 
      "ranges": [ 
       { 
        "from": "2017-02-17T16:00:00Z||-1H/H", 
        "to": "2017-02-17T16:00:00Z||/H" 
       } 
      ] 
     } 
    } 
    } 
} 

Answer 2

あなたはフィールド定義を一致させるために、正規表現を使用するようにReplaceTextを使用し、値に置き換えることができます属性のそれが明示的に定義する方が良いですので、残念ながらすべての番号を繰り返すようにExpression Languageをパラメータには少しトリッキーになります：

• 検索値："Field1"\: ""
• 交換値："Field1": "${field1}"