我正在尝试使用GetHBase进程从Hbase获取数据，结果如下 "row" : "r5", "cf1:ABC:" : "V1", "cf1:HIJ" : "V3",
浏览 9提问于2019-11-13得票数 1
回答已采纳
使用Hbase处理Nifi。在这篇文章中，我从Hbase获取数据，使用Gethbase处理器并将数据发送到Nifi.But中的Putfile处理器。我在Nifi .Any建议中收到错误消息“由于java net连接异常，无法从Hbase接收数据:连接被拒绝”请
浏览 1提问于2016-05-04得票数 0
在我的用例中，我将有一个hbase表，我将在其中使用getHbase读取增量记录，该记录中的一个值应该用作FetchHBaseRow处理器的输入。那么，如何访问流文件中的文件内容并将其用作FetchHbaseRow的输入呢？
浏览 0提问于2018-05-25得票数 1
我正在使用Nifi中的QueryCassandra处理器从Cassandra获取数据来摄取MSSql表。但是我的Cassandra查询总是重复运行，并且我没有任何选项来设置Cassandra Nifi的处理器中的增量或最大值列。如何使用增量Cassandra查询执行Nifi flow？
浏览 51提问于2021-05-09得票数 0
我正在测试NIFI中的一个流，该流使用REST API检查计数器的特定值。我能够从REST响应中提取正确的值。但是，当我在Attribute processor上检查Route中的条件时，预期匹配条件的结果被路由到unmatched processor。我已经检查过我的回答是"1“。我使用的NIFI表达式语言有什么问题吗？
浏览 14提问于2017-12-18得票数 0
回答已采纳
大家好，我从NiFi中的一个主题中得到了一个消息流，我正在通过一个消费者进程阅读这个主题。消息格式为json (虚拟json值，json格式同原)： { "schema": { "name": "emp_table", "emp_sal":
浏览 13提问于2018-12-30得票数 0
回答已采纳
我尝试测试Nifi的功能。我从数据库中提取的数据由名为"id“的特定列组成。我需要使用Nifi将列名转换为"customer_id“。我知道这是一项简单的工作，使用jolt之类的东西。我不想在jolt转换中硬编码来指定列名，而是从其他位置获取列名。有没有这样做的最佳实践或最佳方法？我必须为此编写任何客户处理器吗?如果是这样，那么编写自定义处理器的最佳参考位置是什么？
浏览 24提问于2021-01-08得票数 0
我想从nifi flow中获取数据，然后做一些事情。之后，我想再次将结果发送到nifi flow。 这是我的nifi流，使用输出端口将数据发送到spark。 ? 为了从Nifi flow中获取数据，我编写了以下函数。)
new SiteToSiteClient .url("http://l
浏览 30提问于2020-04-09得票数 1
1回答
我试图理解简单的抖动转换，我有一个简单的1级json，我想改变列的顺序，并将值对象转换成行数组，用逗号分隔的值重复，在Value对象的末尾添加当前日期。，并添加默认标记。"*": { }, "Source": "Dev" }结果joh
浏览 9提问于2022-09-06得票数 1
我是apache NiFi的新手。我希望通过组合特定的字符串和从时间戳字段转换为日期格式的值来指定索引名。我能够使用下面的表达式创建所需的形状，但未能使用内容的时间戳字段的值创建索引名。yyyy-MM-dd')}
"timestamp" :1625579799000,
"data1": "abcd"
浏览 3提问于2021-07-06得票数 0
是否有API点或任何其他可查询的源，可以在其中获取全部排队数据？：在NiFi中设置一个小数据流来监视NiFi本身听起来很粗略，但是如果这是一个常见的实践，那么让我们来做吧。注意：我有一个NiFi实例:我没有也不会实现S2S报告，因为我是在单个实例，单节点NiFi安装程序上
浏览 2提问于2020-04-20得票数 1
回答已采纳
我希望使用apache NiFi将一个处理器结果作为输入传递给另一个处理器。我正在使用ExecuteSQL处理器.i从mysql中获取值，希望将此结果动态传递给apache nifi中的SelectHiveQL处理器。
浏览 1提问于2016-12-08得票数 0
我使用NiFi中的进程QueryDatabaseTable从DB2中增量地获取数据。QueryDatabaseTable计划每5分钟运行一次。最大值列被设置为"rep“(对应于DB2数据库中的日期)。
我有一个单独的MySQL数据库，我想用值"rep“来更新它，QueryDatabaseTable用它来查询DB2数据库。如何获取此值？在日志文件中，我发现Flow
浏览 30提问于2016-07-20得票数 2
例如，我在nifi集群中有3个nifi节点。这些节点的示例主机名；
我知道我可以从所有的nifi节点访问我有用于从rest获取集群摘要的GetHTTP处理器，并且这个处理器只运行在pimary节点上。因此，我将无法从rest获得集群摘要结果。在这种情况下，对于nifi集群中的每
浏览 0提问于2019-01-25得票数 2
回答已采纳
我有一个NiFi流，它需要将数据发布到其他服务器，在发布之前，它需要从我的内部服务器或Nifi分布式缓存中获取一个值。并在发布数据之前将该值添加到Http报头中，当获得特定错误代码401时，该值也被更新。 下面是我正在尝试的流程，所有的绿色处理器都是我能做的，但是我只能获取值并添加到invoke http头中。
浏览 100提问于2020-01-22得票数 0
查看参考资料，例如如何在Nifi (和)、GetSNMP的Nifi源代码(包括AbstractSNMPProcessor)、ListenSysLog、GetFile等中创建自定义处理器。使用库获得了一个简单的( SNMPTrap )接收程序，可以通过UDP或基于SNMP4J的端口监听特定的地址。现在，当尝试将此代码作为自定义处理器在Nifi中编写时，不确定应该将侦听机制放在何处，然后处理实际的PDU部分。有点像在这里。更多详情:-
GetSNMP处理器讨论一个特定的OI
浏览 1提问于2019-03-10得票数 1
回答已采纳
1回答
我有一个csv文件，比如100+列，我只想提取特定的60个列作为子集(两个列名+它的值)。我知道我们可以使用提取文本处理器。，有人能告诉我写的正则表达式吗？例如，从给定的快照中，我只希望NiFi提取'BMS_sw_micro'，'BMU_Dbc_Dbg_Micro'，'BMU_Dbc_Fia_Micro‘列，即只提取列'F，L，O’。
浏览 3提问于2018-09-14得票数 1
我有一个文件并计算了内容的哈希值，但在Java中或使用在线工具进行比较时，它永远不会匹配相同的计算结果。我添加了“debug”级别的处理器日志，但它没有帮助。
每
浏览 1提问于2018-12-18得票数 0
1回答
我正在使用Nifi从远程服务器获取文件:我的文件如下所示：12345,x,12.412348,x,13.412355,y,12.012345,x,12.4,3
12346,x,1
浏览 3提问于2018-03-06得票数 0
回答已采纳
我们使用HDF从oracle获取大量数据。Nifi使用jdbc连接，因此是否有甲骨文端配置。
另外，如果我们在查询示例/parallel(c,2)/中添加了并行性提示。WIll这个帮助？
浏览 0提问于2019-03-05得票数 0
回答已采纳
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
