这个数字我应该放到下一个getToken中作为GET参数之一(在屏幕截图上我硬编码了这个)： ? ? 这将返回一个令牌。Token是一个text/plain;charset=UTF-8。我真的不知道如何在以下处理器中使用从处理器接收到的数据。有人能解释一下如何用我的流程到达它吗？
浏览 33提问于2020-12-10得票数 1
回答已采纳
我为我的文档创建了Azure CosmosDb数据库和容器。我使用NiFi作为主要的数据摄取工具，并希望为我的容器提供来自NiFi流文件的文档。有没有人可以分享一下从NiFi向Azure Cosmos Db发布流文件内容的方法？更新(2019.05.26)：最后我使用了Python script，并从NiFi调用它来发布消息。
浏览 5提问于2018-12-09得票数 1
我想使用apache nifi将数据从oracle传输到MongoDB。Oracle总共有900万条记录。我已经使用QueryDatabaseTable和PutMongoRecord处理器创建了nifi flow。此流程运行良好，但存在一些性能问题。在启动nifi流之后，SplitJson -> PutMongoRecord队列中的记录不断增加。有没有办法降低SplitJson处理器放入队列中的记录的速度？现在，在30分钟内插入
浏览 8提问于2020-06-29得票数 0
我感兴趣的是创建一个在工业PC上运行的软件，连接到某些机床的CNC模型，读取数据，并将其发送到远程云平台。根据需要，数据必须以MTConnect的XML schema格式发送。此外，数据传输必须使用MQTT协议来完成。
为了开发这个系统，我正在考虑使用Apache Nifi。我们的想法是开发自定义nifi处理器，以使用相应的API连接到特定的数控模型，并在下一步中使用另一个nifi处理器来应用MTConnect语义层
浏览 13提问于2017-12-21得票数 2
1回答
如何确保流的安全，即如何断言只有授权的应用程序才能向NiFi提交数据？例如，我是否可以将流连接到LDAP，在其中我将注册所有调用者及其权限(和策略)？我只看到了保护登录用户的NiFi的可能性，但这与我的问题无关。
浏览 1提问于2017-10-27得票数 0
我的最终目标是屏蔽特定文件中的数据。我想要将文件从一个位置移动到另一个位置。在此传输过程中，我必须使用Python脚本屏蔽数据。我在Google Cloud Platform上创建的虚拟机上运行此NiFi，其中我安装了Python-2.7和NiFi-1.9.1。处理器。2)另外，在我的Python代码中，我试图从传入GetFile处理器的同一个输入目录中读取数据，但现在该文件已被移到getfile > exec
浏览 1提问于2019-04-25得票数 0
我希望使用NiFi rest将流文件传输到输入端口。我正在浏览NiFi rest文档，发现似乎有实现相同目标的支持。然而，诚实并不是很清楚，也不是很详细。我的工作流程如下：源处理器组中的：
目标处理器组中的：
我想知道的是如何将排队的流文件从源处理器组传输到目标处理器组的输入端口，以便使用PutFile存储。我想尝试到达这个端点：http://localhost:8080/nifi</
浏览 2提问于2017-04-05得票数 0
我是Nifi的新手，正在寻找有关使用Nifi处理器以获得高达100MB/s速度的信息。
浏览 29提问于2020-04-10得票数 0
回答已采纳
我正在尝试编写一个函数，它接受两个参数，一个在nifi实例A中的处理器ID和一个在nifi实例B中的输入端口，并在nifi实例A中创建一个RPG，它将上面的内容连接到上面。现在，我是怎么做的
发送到/nifi/process-group
浏览 3提问于2017-05-04得票数 1
回答已采纳
我正在尝试使用NiFi在具有相似表结构的两个数据库之间传输数据。数据结构示例：没有“最大值列”，因此不可能确定是否有新数据。问题是不清楚是否应该在目标数据库中插入或更新特定的记录。
我创建了处理器的两个分支:插入和更新。只有insert才适用于新记录，而update只适用于现有记录。但是(!)PutSQL处理器可以处理大量的流文件
浏览 1提问于2017-03-29得票数 2
1回答
我们有高达8 8GB的文件，其中包含结构化内容，但重要的元数据存储在文件的最后一行，需要附加到每一行内容。使用ReverseFileReader获取最后一行很容易，但这需要文件在磁盘上是静态的，而我无法在现有的Nifi流中找到这样做的方法？在数据流到内容存储库之前，这是可能的吗？
浏览 43提问于2019-06-22得票数 1
回答已采纳
1回答
我正在寻找一个可靠的数据传输方法之间的不同的Nifi集群。我有两个Nifi集群-一个从源获取数据，另一个用于将数据推送到Hive/HDFS中。我需要将数据从第一个nifi集群传输到另一个nifi集群。nifi中是否有任何组件可用于此操作？从端口读取的Nifi集群2->发布到H
浏览 4提问于2017-10-12得票数 0
回答已采纳
1回答
一种是包含Nifi的hdf集群，另一种是包含HDF、Hive等组件的HDP集群。我们正在从文件中读取数据，并希望将其放入hdp群集hdfs中。提前感谢
浏览 1提问于2016-10-28得票数 0
1回答
当下一个处理器无法接收或处理任何数据时，有人能详细解释NiFi处理器(如GetFile或QueryDatabaseTable )是如何存储行的吗？当数据的大小超过某个阈值时，数据会在内存中通过管道传输到磁盘上吗？它是否有耗尽内存或丢失数据的风险？
浏览 4提问于2017-05-15得票数 5
回答已采纳
我们正在尝试使用Apache将数据从RDBMS迁移到弹性搜索。我们已经在Nifi创建了管道，能够传输数据，但也面临一些问题，我们希望检查是否有人已经克服了这些问题。
请就下列项目提供投入。1.在弹性搜索中如何避免自动生成_id。我们希望从DB列中设置这个值。我们尝试在PutElasticSearchHTTPRecord处理器中的“标识符记录路径”属性中提供列名，但是得到了一个属性名无效的错误。请告诉我们可以接受的格式好吗？如何使用NIfi</e
浏览 5提问于2020-07-16得票数 0
如果提交到NiFi的数据不是以稳定的流(而是突发性的)传入的，NiFi如何处理它们？它是否使用消息代理来缓冲它们？我还没有在它的文档中看到过类似的东西。
浏览 1提问于2017-10-27得票数 0
1回答
因此，我设置了一个NiFi 1.9.0服务器，放入一个ListenTCP处理器和一个PutTCP处理器，配置适当的I和端口并连接它们。到目前为止，这些数据包被ListenTCP处理器接收，也被PutTCP处理器存储。
但是NiFi似乎在处理数据，发送的数据包与接收的数据包不完全相同。我一直在处理ListenTCP处理器上的字符集、最大批处理大小和批处理消息删除器设
浏览 2提问于2019-03-11得票数 1
在Apache1.15版本的NiFi中，创建了一个由3个NiFi节点组成的集群。当通过默认端口6342使用负载平衡时，流文件会卡在一些队列中，即在启用负载平衡的队列中。已印发：
流文件似乎被卡在其中的NiFi队列的配置：
另一个可能与此无关的问题是，在这种情况发生后，一些流文件会到达后续的NiFi处理器参数"max_num_for_merge_smxs“设置为100：
浏览 4提问于2022-03-08得票数 3
我正在考虑创建一个自定义处理器，用于从没有现有nifi处理器的自定义来源获取数据。我一直在尝试理解Nifi组件如何工作的机制，并看到了一些关于如何创建自定义处理器的优秀文档，然而，我看不到任何关于管理偏移量的内容。假设我有一个运行1秒的处理器，但需要从某个任意的偏移量继续处理，这可能会也可能不会每秒产生结果。我目前的理解是"onTrigger“方法是实现这种逻辑的地方，然而，我不确定Nifi中是否有任何机制可以用来标记以前执
浏览 3提问于2020-03-01得票数 0
我目前正在使用ListenHTTP处理器来接受来自不同NiFi实例的流文件。这很好，但出于某种原因，GET请求不起作用。ListenHTTP只允许发布请求吗？这是我收到的错误：我知道有一个更先进的HandleHTTPRequest处理器。
浏览 4提问于2016-11-28得票数 1
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号