从NIFI调用API

Question

我有一个需求，需要在成功的数据转储到cassandra表的末尾调用API。我在我的nifi流中使用了下面的处理器。

QueryDataBaseTableRecord -> SplitLines --> ExecuteScript -> PutCassandraQL --> InvokeHTTP -> Invoke HTTP --> PutS3

Usecase:需要将数据从DB2转储到DB2，在成功转储之后，它应该首先调用API InvokeHTTP (该API必须将大约100 k的记录转储到DB2，并以“数据插入”的形式将响应消息发送回nifi)，一旦我们得到响应消息，就需要调用第二个InvokeHTTP。

问题是Nifi自动路由到故障流(大约1分钟后)，因为它没有等待来自第一个调用API的响应消息，但是当我们在后端检查时，数据转储仍在进行中。

谁能让我知道-如何使invokehttp处理器等待API响应消息和路由到下一步？感谢您的建议，如果有任何其他有效的/替代的方法，我们可以尝试处理这一用途。

Answer 1

如果检查InvokeHTTP的配置，就有两个超时字段：

1. 连接超时
2. 读取超时

只需增加这些的价值。

这是文档