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

Question

我想使用 NiFi rest api 将流文件传输到输入端口。我正在浏览 NiFi rest api 文档，发现似乎有支持来实现相同的目标。但是，说实话不是很清楚或很详细。

我的工作流程是这样的：

父级视图

内部源处理器组：

内部目标处理器组：

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

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

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

注意：我知道我可以使用 NiFi 的 Web UI 来做到这一点，但我想知道如何使用 NiFi 的 REST API 来完成。

Answer 1

您需要使用这些端点来创建事务。这是 NiFi 使用 Site-To-Site 客户端库与这些端点 [1] 通信的源中一个点的链接。发送流文件不是一个简单的调用，因为您需要创建事务、发送内容、确认事务，然后完成它。

[1]https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-site-to-site-reporting-bundle/nifi-site-to-site-reporting-task/src/main/java/org/apache/nifi/reporting/SiteToSiteProvenanceReportingTask.java#L206