Интеграция сервисов MiNiFi и NiFi

ADS предоставляет, помимо NiFi и MiNiFi, поддержку централизованного управления MiNiFi Agent с помощью MiNiFi C2 Server. Данный сервис обеспечивает автоматическое обновление конфигураций MiNiFi Agent без сторонних вспомогательных средств. В данном разделе приведены основные шаги для настройки взаимодействи между MiNiFi и NiFi сервисами:

Создание шаблона

Для выполнения какой-либо задачи MiNiFi Agent необходимо создать шаблон в UI NiFi. В данном разделе представлен элементарный шаблон для сбора содержимого файла с машин MiNiFi Agent.

После установки NiFi и MiNiFi с помощью ADCM, в разделе Template появляется шаблон с название simple-minifi-listener, который состоит из следующих элементов (Рис.99.).

../_images/minifi_simple-minifi-listener.png

Рис. 99. Основные элементы шаблона

Чтобы создать шаблон для Агентов, необходимо перейти в MiNiFi Process Group и создать Flow, который будет выполнятся непосредственно MiNiFi Agent.

В нашем случае созданный Flow (Рис.100.) содержит процессор TailFile, который считывает содержимое файла и передает экземпляру NiFi

../_images/minifi_flow.png

Рис. 100. Flow Агентов

Для успешной загрузки Flow на MiNiFi Agent, необходимо сохранить шаблон с названием указанным в nifi.minifi.notifier.ingestors.pull.http.query с добавлением версии (например, minifi.v1). Если вы изменили Flow, то для актуализации его на агентах необходимо увеличить версию шаблона (например, minifi.v2)

Автоматическое обновление конфигурации MiNiFi Agent происходить с периодичностью, заданной nifi.minifi.notifier.ingestors.pull.http.period.ms. Если шаблон был неправильно собран, то Агенты продолжат работу на последней работоспособной конфигурации.

Проверка конфигурации

Текущую конфигурацию Flow, которую запрашивают MiNiFi Agent у MiNiFi C2 Server, можно проверить, обратившись к API MiNiFi C2 Server (Рис.101.). Ссылка указана в описании сервиса MiNiFi в ADCM.

../_images/minifi_c2_api.png

Рис. 101. Результат обращения к MiNiFi C2 Server