NiFiのキューをクリアするには？

Question

私たちはNiFiでいくつかのフローを作成しています。キューが構築されている場合もありますが、何らかの理由でフローが期待通りに機能しない場合があります。

一日の終わりに、キューをクリアして何とかそれを自動化したいと思います。問題は、バックエンドからキューを削除する方法です。それを達成する方法はありますか？

Answer 1

Bryanが述べた明示的な「Drop Queue」機能に加えて、接続の「Back Pressure」と「FlowFile Expiration」の設定があります。これにより、任意の接続内のデータ量を自動的に制御することができます。それぞれの簡単な説明は以下にありますが、詳細な説明についてはApache NiFi User Guideを参照してください。

バックプレッシャー：キューが一定のサイズになると、それを供給しているプロセッサがトリガーされなくなります。

FlowFileの有効期限：FlowFileがキューにX時間を費やすと、それは破棄されます。

Answer 2

Apache NiFi UIでキューを右クリックすると、キューを空にするオプションがあります。あなたがUIに何かできることは、RESTサービスに裏打ちされたので、RESTのAPIドキュメントを見てみましょうされています

https://nifi.apache.org/docs/nifi-docs/rest-api/index.html

/flowfile-キュー/ {ID} /ドロップ要求に具体的にPOSTを。

また、Chromeを使用して開発ツールを開いているときに、アプリケーションを使用して特定の操作を実行したときにREST APIにどのような呼び出しを行うかを確認することもできます。