Nifi Merge JsonファイルをJsonArrayに変換

Question

プロセッサ/フローJsonMessagesをMergeContentを使用してJsonArrayに併合して変換したい場合は、考慮しないのですか？私は、複数のファイルからJsonArraysを構築し、QueryRecordに渡してSQLを実行しようとしました。私はそれを行うための箱/明白な方法を欠いている良いチャンスです。どんな助けでも大歓迎です。

私はgroovy実行スクリプトを使用できましたが、可能であればカスタムコードを避けたいと考えていました。ありがとう！

メッセージIn - > MergeContent - > ConvertToJsonArray - > QueryRecord。

Answer 1

MergeContentを使用して、区切り文字ストラテジーを「テキスト」に設定し、ヘッダー、デマーケーター、およびフッターのそれぞれに[、]を入力することができます。

これは、フローファイルの先頭にヘッダー、すべてのフローファイルと最後のフッターの間の境界線を挿入します。

また、レコードのものを使用しているように見えるので、最新のリリースでは、JsonTreeReaderとJsonRecordSetWriterを使用した場合、これを処理するMergeRecordプロセッサが必要です。