如何使用NiFi API在NiFi中传输流文件？

Question

我希望使用NiFi rest将流文件传输到输入端口。我正在浏览NiFi rest文档，发现似乎有实现相同目标的支持。然而，诚实并不是很清楚，也不是很详细。

我的工作流程如下：

父级视图

​

源处理器组中的：

​

目标处理器组中的：

​

我想知道的是如何将排队的流文件从源处理器组传输到目标处理器组的输入端口，以便使用PutFile存储。

我想尝试到达这个端点：http://localhost:8080/nifi-api/data-transfer/input-ports/{portId}/transactions/{transactionId}/flow-files

虽然我可以从输入端口获得portId，但我不知道transactionID是什么，也不知道从哪里可以得到它。

备注：我知道我可以使用NiFi的web来完成这个任务，但是我想知道如何使用NiFi的REST来完成同样的任务。

Answer 1

您需要使用这些端点来创建事务。这里的链接指向源代码中的一个点，其中NiFi使用站点对站点客户端库与这些端点1通信。发送流文件并不是一个简单的调用，因为您需要创建事务、发送内容、确认事务，然后完成它。

1