当前位置: 首页 > 知识库问答 >
问题:

如何使用NiFi API在NiFi中传输flowfiles?

阎弘雅
2023-03-14

我想使用NiFi rest api将flowfiles传输到输入端口。我浏览了NiFi rest api文档,发现似乎有支持来实现同样的功能。但是,说实在的,不是很清楚,也不是很详细。

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

我想尝试点击以下endpoint:http://localhost:8080/nifi-api/data-transfer/input-ports/{portId}/transactionId}/flow-files

共有1个答案

潘刚洁
2023-03-14

您需要使用这些endpoint来创建事务。下面是指向源代码中NiFi使用站点到站点客户端库与这些endpoint通信的位置的链接[1]。它不是发送flowfile的简单调用,因为您需要创建事务、发送内容、确认事务,然后完成它。

[1]https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-site-to-site-reporting-bundles/nifi-site-to-site-reporting-task.java#l206

 类似资料:
  • 我正在使用Apache NiFi从数据库表中提取数据,并使用将获取的记录从avro更改为使用和的CSV文件。 当至少有一行从数据库返回时,我的流程工作正常。 但是,当处理器输出一个包含0条记录的FlowFile(该FlowFile仍然包含元数据/avro模式)时,会给出一个0字节的FlowFile输出。我在服务中的设置被设置为输出标头。 在这种情况下,有没有办法让输出一个只包含标题行的FlowFi

  • 我必须在nifi进程中使用aws临时凭证AccessKey、SecretKey和令牌来访问S3对象。AccessKey、SecretKey和Token将由Api调用提供。如何在nifi ListS3对象等中使用这些临时凭证? 我发现的选项之一是使用AWSCre的alsProviderControlllerService,因为这可以根据API调用更新控制器服务的值吗? 在这个场景中我还可以使用其他选

  • 有一个特定的处理器,正如下面提到的,我对它感兴趣,与1.2.0相比,1.5.0中有一个额外的特性,所以我想使用它。 我看到有两种方法。 以上处理器存储为nifi-standard-nar-x.x.x.nar-unpacked文件。所以只需从1.5.0复制Nar,并将其放在1.2.0上即可。在此之后,我不确定nifi是否会识别这个新的处理器版本? 上面的处理器是下面文件的一部分,因此从它中创建一个新

  • 问题内容: 我如何通过iPhone将Over WatchConnecitivity 从iPhone转移到Apple Watch,而无需在手机上进行用户交互,而只能加载,因为手表以编程方式对其进行调用。我之所以需要这样做,是因为图像处理用于创建Watchkit API中不可用的使用逻辑,因此必须通过手机进行创建。我似乎有一些使用Watch Watch连接的示例: 但是,我是Watch Kit的新手,

  • 我使用此命令从Raspberry摄像机流式传输实时视频: 我需要一种通过netcat传输H.264文件的方法,如上面的示例所示。它的接收方式必须与我的覆盆子相机相同。

  • 编辑 根据daggett的评论,我有rest API-http://localhost:8080/nifi-api/flow/公告牌,它解决了我的一半问题。现在我需要知道谁可以获得导致公告的flowfile详细信息。