apache nifiを使用してあるプロセッサから別のプロセッサに動的に値を渡す方法

Question

apache NiFiを使用して別のプロセッサに入力として1つのプロセッサ結果を渡します。

私はExecuteSQLプロセッサを使用してmysqlから値を取得しています.iこの結果をapache nifiのSelectHiveQL Processorに動的に渡します。

Answer 1

ExecuteSQLはAvroとして結果セットを出力します。個々の行を個別に処理する場合は、SplitAvro、次にConvertAvroToJson、またはConvertAvroToJsonをSplitJsonとすることができます。この時点でEvaluateJsonPathを使用して属性に値を抽出し（NiFi Expression Languageと一緒に使用する）、フローファイルの内容を（SelectHiveQLで使用する）HiveQLステートメントに設定する場合はReplaceTextとなることがあります。