Как перенести потоковые файлы NiFi из одной очереди в другую? - PullRequest
0 голосов
/ 29 апреля 2020

У меня есть «несопоставимые» потоковые файлы в очереди. Есть ли способ передать эти потоковые файлы в другую очередь?

enter image description here

РЕДАКТИРОВАТЬ:

С ПРЕДЛОЖЕННЫМ РЕШЕНИЕМ @ Энди - # РАЗРЕШЕНО

enter image description here

Ответы [ 2 ]

2 голосов
/ 29 апреля 2020

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

1 голос
/ 29 апреля 2020

Ответ Брайана является всеобъемлющим и объясняет идеальный процесс для постоянного успеха. Если это одноразовая задача ( У меня есть эта очередь, содержащая данные, которые я использовал во время тестирования; теперь я хочу, чтобы она была go для этого другого процессора ), вы можете просто выбрать очередь, содержащую данные и перетащите синюю конечную точку на другой компонент.

...