Мы создаем потоки в NiFi, и могут быть случаи, когда очереди наращиваются, но по какой-то причине поток не работает должным образом.Как очистить очереди NiFi?
В конце дня я хотел бы очистить очереди и как-то хотел бы автоматизировать его. Вопрос в том, как мы можем удалить очереди из бэкэнда? Есть ли способ достичь этого?
В дополнение к явной функции «Опускать очередь», о которой говорил Брайан, вам понадобятся еще две функции, которые могут вас заинтересовать: настройки «Back Pressure» и «FlowFile Expiration» при подключении. Они позволяют автоматически управлять объемом данных в любом соединении. Простое объяснение для каждого из них ниже, но для более подробного объяснения я приведу вас к Apache NiFi User Guide
Back Pressure: Когда очередь достигает определенного размера, остановите запуск процессора, который его подает.
Истечение срока действия FlowFile: как только FlowFile потратил X в очереди, он будет удален.
В пользовательском интерфейсе Apache NiFi, если вы щелкните правой кнопкой мыши по очереди, есть опция для опорожнения очереди. Все, что вы можете сделать в пользовательском интерфейсе поддерживается службой REST, чтобы взглянуть на API Docs REST:
https://nifi.apache.org/docs/nifi-docs/rest-api/index.html
конкретно POST к/flowfile-очередями/{ID}/раскрывающиеся запросы.
Вы также можете использовать Chrome и открывать инструменты разработчика, используя приложение, чтобы узнать, какие вызовы он делает для API REST при выполнении определенных действий.
Что делать, если пустая очередь каким-то образом выходит из строя, оставляя очередь неспособной удалить - есть ли способ принудительно остановить очередь? – serup
Я искал истечение срока действия FlowFile, и это решило мою проблему. –