NiFi:运行ExecuteStreamCommand处理器，如果失败，尝试次数有限

Question

我在NiFi中有一个处理器，看起来像这样：

基本上，ExecuteStreamCommand将运行一个Python脚本来执行一些处理，然后流文件将转到RouteOnAttribute来检查上一个Python脚本是否成功运行。如果成功，它将进入下一个处理器（我在这个图中没有显示）。但如果失败，flowfile将转到另一个ExecuteStreamCommand处理器发送警报通知（通过电子邮件、聊天等）。然后它将再次运行第一个ExecuteStreamCommand，直到脚本运行时没有出现错误。你知道吗

我这里的问题是，如果python脚本中有错误，它将一直保持警报，直到我暂停处理器。因此，是否有任何其他处理器或设置要添加到此流中，以便在出现错误的情况下，每次将重新运行Python脚本进行有限的尝试（此管道设置为每小时运行一次，因此应分别计算每个流文件的自动重试次数）。或者我必须为此在python脚本中添加任何代码吗？你知道吗

TL；博士 我正在寻找一个NiFi处理器添加到我的管道中，它可以帮助我计算同一个流文件通过处理器的时间，从而限制python运行脚本的自动恢复

Answer 1

有几种方法可以实现它。你知道吗

• 您可以在属性上添加路由，并跟踪此属性上的重定时数。你知道吗
• 在脚本中处理它
• 使用惩罚函数：https://community.hortonworks.com/questions/56167/is-there-wait-processor-in-nifi.html

一些参考：how to control retries of invoke HTTP processor in nifi