apache-nifi - 如何重试 InvokeHTTP 处理器特定的时间

Question

我正在使用 InvokeHTTP 处理器从 API 获取 JSON 数据。标准是：如果没有获取数据，它将重试 3 次，如果仍然失败，它将通过电子邮件发送通知。我是 NiFi 的新手，那么我该如何实现呢？

标签： apache-nifi

Answer 1

您可以使用自定义工作流程重试特定次数。从调用 HTTP 获得响应后，您可以将值为 0 的计数器属性设置为，如果您没有从 API 获得响应，您可以将该属性增加一并将流文件发送回调用 http 的输入。每次收到 API 的响应时，您可以检查该属性是否达到最大重试值，如果达到，您可以根据您的要求终止数据。