groovy - 在 NiFi 中捕获上一个处理器的名称
问题描述
我正在寻找创建一个错误处理流程，并且只需要在特定点上捕获故障处理器的名称。更新属性将是最后的手段，因为它会使模板混乱。理想情况下，我正在寻找脚本或类似内容，但我愿意听取 NiFi 专家的建议。
解决方案
您可以通过手动检查或 REST API 使用Data Provenance功能，但根据设计（“基于流的编程”），Apache NiFi 中的组件是独立的黑盒，不知道它们的前任和后继。
如果您需要编程功能来访问错误消息，请查看SiteToSiteBulletinReportingTask. 使用此组件，您可以通过站点到站点将公告发送回相同（或不同）的 NiFi 实例，并将它们作为任何其他任意数据进行摄取和处理。