Apache Nifi を使用して、Json ファイルを読み取り、内容が正しいかどうかを検証するために行ごとに分割するフローを作成しました。その後、2 つの出力があります。1 - 成功した行の場合と 2 - 失敗した行の場合で、出力は Json ファイルです。
今のところ、すべての行は別々のファイルに保存されていますが、私がやりたいのは、「良い」行を 1 つのファイルに保存し、「悪い」行を別のファイルに保存することです。
どのプロセッサーを使用すればよいですか?
Apache Nifi を使用して、Json ファイルを読み取り、内容が正しいかどうかを検証するために行ごとに分割するフローを作成しました。その後、2 つの出力があります。1 - 成功した行の場合と 2 - 失敗した行の場合で、出力は Json ファイルです。
今のところ、すべての行は別々のファイルに保存されていますが、私がやりたいのは、「良い」行を 1 つのファイルに保存し、「悪い」行を別のファイルに保存することです。
どのプロセッサーを使用すればよいですか?
RouteText プロセッサは、まさにあなたがしようとしていることのために設計されました。作成した式に基づいて、テキスト行をさまざまな関係にルーティングできます。これは、関係ごとに各 FlowFile の行をまとめます。
ここでドキュメントを見ることができます: https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi.processors.standard.RouteText/index.html
ここで RouteText を使用してサンプル テンプレートを取得できます (やりたいこととほとんど同じです): https://github.com/hortonworks-gallery/nifi-templates/blob/master/templates/SplitRouteMergeVsRouteText.xml