有人能告诉我如何让invokehttp处理器等待API响应消息并路由到下一步吗?感谢您的建议,如果有任何其他有效的/替代的方法,我们可以尝试处理这一用途。
如果检查配置ot InvokeHTTP,则有两个超时字段:
只是为那些增加价值。
我已经为HDFS中的数据摄取开发了一个NiFi流原型。现在我想提高整体表现,但似乎我不能真正前进。对此,作者提出了建议 该流接收输入csv文件(每行有80个字段),在行级别拆分它们,对字段应用一些转换(使用4个顺序执行的自定义处理器),将新行缓冲到csv文件中,然后将它们输出到HDFS中。我以这样一种方式开发了处理器,即当读取每个记录并将其字段移动到flowfile属性时,只访问一次流文件的内容。
我想使用NiFi rest api将flowfiles传输到输入端口。我浏览了NiFi rest api文档,发现似乎有支持来实现同样的功能。但是,说实在的,不是很清楚,也不是很详细。 我想知道的是,如何将排队的流文件从源处理器组传输到目标处理器组的输入端口,以便使用存储。 我想尝试点击以下endpoint:
有一个特定的处理器,正如下面提到的,我对它感兴趣,与1.2.0相比,1.5.0中有一个额外的特性,所以我想使用它。 我看到有两种方法。 以上处理器存储为nifi-standard-nar-x.x.x.nar-unpacked文件。所以只需从1.5.0复制Nar,并将其放在1.2.0上即可。在此之后,我不确定nifi是否会识别这个新的处理器版本? 上面的处理器是下面文件的一部分,因此从它中创建一个新
我为我的文档创建了 Azure CosmosDb 数据库和容器。我使用NiFi作为主要的数据摄取工具,并希望用NiFi流文件中的文档来馈送我的容器。任何人都可以分享一种从NiFi将flowfile内容发布到Azure Cosmos Db的方法吗? 提前致谢 更新(2019.05.26):最后我用Python脚本,从NiFi调用来发布消息。我传递了一条消息作为参数。我选择python的原因是因为它在
NiFi在JOLT处理器中抛出了一个错误--尽管在“高级”处理器接口中的测试工作完美无缺! 以前有人遇到过这种错误吗?
Apache NiFi 是一个易于使用、功能强大而且可靠的数据处理和分发系统。Apache NiFi 是为数据流设计。它支持高度可配置的指示图的数据路由、转换和系统中介逻辑。 架构: 集群管理器: 主界面: 关键特性包括: 基于web的用户界面 无缝体验设计、控制和监视 高度可配置的 数据丢失容错和保证交付 低延迟和高吞吐量 动态优先级 流可以在运行时修改 背压 Back presure 数据来源