Apache NifiでExecuteSQLプロセッサー

Question

Apache Nifiを使用しているときに問題が発生しています。 ExecuteSQLプロセッサが手動で停止するまで繰り返しフェッチするのではなく、テーブル内のすべてのデータをフェッチし終えたら、ExecuteSQLプロセッサを停止する方法はありますか？

Answer 1

一般的にプロセッサは、スケジューリングタブを使用してある頻度でスケジュールされます。グラフの途中に入ってくるプロセッサでは、通常、スケジューリングは0秒になります。これは、データがキューに入っているときにできるだけ早く実行されることを意味します。ソースプロセッサは、通常、タイマードライバまたはCron駆動スケジューリングに基づいて、ある間隔で動作します。

ExecuteSQLは、入ってくるフローファイルによってトリガされることをサポートしているので、ListenHTTPプロセッサをExecuteSQLの前に置いて、それをトリガしたいときはいつでもhttpエンドポイントを呼び出すようにすることができます。 ListenHTTPのポイント。このようにして、実行しておくことができますが、必要なときにだけ起動されます。