呼び出し間でプロセッサの状態を保持/保存するメカニズムはありますか? 特に、プロセッサや NiFi 自体が再起動された場合でも、プロセスが最後にいつ実行されたかを知る信頼できるメカニズムが必要です。
(hBase やファイル システムなどの回答はしないでください。NiFi が提供するもの、または NiFi が提供するサービスで構築できるものを探しています)
1 に答える
3
現在、すべてのプロセッサのアプリケーション全体でリストされた情報を一方的に自動的にキャプチャするすぐに使える機能はありません。
DistributedMapCacheServer /Client やDistributedSetCacheServer /Clientのような ControllerServices を介してコンポーネントでこのタイプの機能を実現する機能を提供するメカニズムがあります (これらは分野横断的な関心事または側面のコンポーネントと考えてください) 。
DetectDuplicateやListHDFSなど、目的の機能に類似した方法でこれらのコントローラー サービスを利用するプロセッサがあります。
これが現在の状況です。そのようなタスクを達成するためのより多くのフレームワーク機能をもたらす次のリリース (0.5.0) に向けて進行中の作業があり、その作業はState Management Feature Proposalで概説されています。
これらのアイテムのどれもあなたの希望する機能に完全に適合しない場合、または他のアイデアがある場合は、メーリング リストやJIRAを介してコミュニティと共有することをお勧めします。
于 2016-01-01T01:19:44.713 に答える