Есть ли механизм сохранения / сохранения состояния процессора между вызовами? В частности, я хочу, чтобы надежный механизм знал, когда мой процесс последний раз запускался, даже если процессор или даже сам NiFi был перезапущен.

(Пожалуйста, не давайте таких ответов, как hBase или файловая система. Я ищу что-то, что предоставлено NiFi или что может быть создано с помощью услуг, предоставляемых NiFi)

charles

Ответы (1)

В настоящее время нет готовой функциональности, которая автоматически захватывает перечисленную информацию в одностороннем порядке во всем приложении для всех процессоров.

Существуют механизмы, которые обеспечивают возможность выполнения этого типа функций в компонентах через ControllerServices (воспринимайте их как компоненты для сквозных задач или аспектов), например DistributedMapCacheServer/ Client или DistributedSetCacheServer/ Клиент.

Существуют процессоры, которые используют эти службы контроллера аналогично желаемой функции, например DetectDuplicate или ListHDFS.

Вот где дела обстоят сейчас. В настоящее время ведется работа над следующим выпуском (0.5.0), который принесет больше функциональных возможностей фреймворка для выполнения таких задач, и его работа описана в нашем Предложении функции управления состоянием.

Если ни один из этих элементов не соответствует вашим желаемым функциям или у вас есть другие идеи, я рекомендую вам поделиться ими с сообществом через наши списки рассылки , если вы хотите обсудить свои идеи и / или JIRA.

2022 WebDevInsider