NiFi - управление порядком слияния двух потоков данных с процессором EnforceOrder и MergeContent

Question

Я пытаюсь использовать процессор EnforceOrder для выполнения слияния в определенном порядке.Для этого это мой поток:

В атрибуте updateAttribute я создаю атрибут для установки порядка, который я хочу в слиянии.С одной стороны, я устанавливаю значение «1», а с другой, я устанавливаю значение «2».

И тогда конфигурация EnforceOrder будет следующей:

Проблема в том, что поступает только поток process.order = 1 и не вынимает число 2. Что я делаю не так?

Приветствия

Answer 1

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

• с использованием *Процессор 1012 * добавляет порядковый номер в файл потока.

Пример:

• Рассмотрим 2 файла потока, Flowfile-2 (этот контент должен будет отображаться в первую очередь) будет иметь меньшее значение sequence number по сравнению с flowfile1 , а затем передать подключение success к процессору MergeContent. Используя процессор принудительного исполнения, мы делаемуверен, что flowfile2 будет работать с Mergecontent процессором до flowfile1.

Пожалуйста, обратитесь к this и используйте шаблон принудительного порядка, чтобы ознакомиться с enforce order процессор.

ОБНОВЛЕНИЕ:

Я думаю, что проблема связана с конфигами EnforceOrder,

• Идентификатор группы настроен как ${filename}, поэтому, если у вас два разных имени файла, процессор не будет ждать обоихдля них.

• Чтобы исправить этот Keep общий атрибут в UpdateAttribute процессоры, такие как group_name как gn, затем используют то же имя атрибута в Идентификатор группы Значение свойства как ${group_name}

• Подключение Skipped and Wait подключений к процессору EnforceOrder самостоятельно.

UpdateAttributeConfigs:

EnforceOrderConfigs:

Пожалуйста, используйте этот шаблон в качестве ссылки и загрузите его в свой экземпляр NiFi, чтобы проверить, как работает потокбежал.