带有NiFi处理器的PutSQL中的错误日志记录

Question

当管道中的my_logging_table Put处理器失败时，我希望将NiFi行作为日志插入。到目前为止，我不得不为创建另一个日志-处理器--每个管道处理器，它具有以下sql-statement

insert into schema.my_logging_table values
('Failed-NiFi-processor-name', 'failed', current_timestamp)

这显然导致NiFi处理器的数量翻了一番，因为每个处理器都必须有自己的“logging-putsql处理器”，这样才能记录正确的处理器名。

是否有办法让我的管道-putsql-处理器在失败时更新流文件属性(我正在考虑传递处理器的名称)？

通过这种方式，我可以将所有故障路由到单个日志-putsql处理器，该处理器从文件属性中读取失败处理器的名称，并将该行插入数据库。我注意到了"update_attribute“处理器，但是我必须为每个处理器构建一个处理器.

Answer 1

是的，您需要将一个UpdateAttribute放在故障分支上，并不是所有的处理器都会编写失败属性。您将看到它们在处理器文档中写入了哪些属性--参见PutSQL的写属性部分

或者，你可以

1. 创建一个流来解析nifi-app.log并查找错误
2. 创建一个捕获所有公告的SiteToSiteBulletinReportingTask流，将其发送到RPG，筛选PutSQL失败，发送到DB，等等。