Захват имени предыдущего процессора в NiFi

Question

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

Answer 1

Вы можете использовать функцию Data Provenance для этого через ручную проверку или REST API, но в соответствии с замыслом (« Flow Based Programming ») компоненты в Apache NiFi независимы от черных ящикови не знают своих предшественников и преемников.

Если вам нужна программная возможность доступа к сообщениям об ошибках, посмотрите SiteToSiteBulletinReportingTask.С помощью этого компонента вы можете отправлять бюллетени обратно в тот же (или другой) экземпляр NiFi через Site-to-Site и получать и обрабатывать их как любые другие произвольные данные.