腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(8046)
视频
沙龙
1
回答
有没有
办法
通知
Nifi
处理器
elasticsearch
、
apache-nifi
、
data-migration
我有一个
NiFi
流,在这个流中,我从elasticsearch获取数据,经过一些处理后,我将流文件保存在目标位置。一旦保存了所有的流文件,我希望
通知
合并进程将文件中的所有数据合并到一个大的csv文件中。我的问题是如何
通知
合并
处理器
现在所有文件都已保存,并且现在开始合并所有文件。 谢谢你的帮助..:)
浏览 64
提问于2021-08-09
得票数 0
1
回答
使用
NiFi
使用QueryDatabase表读取记录时限制行数
database
、
apache-nifi
我正在尝试使用Apache
NiFi
的QueryDatabase
处理器
,
有没有
办法
限制记录,比如:“select* from table 100”
NiFi
中是否有其他支持此操作的
处理器
?
浏览 0
提问于2018-11-20
得票数 2
1
回答
如何只停止第一个
处理器
apache-nifi
有没有
办法
只停止
NiFi
进程组的第一个
处理器
? 我知道通过
Nifi
可以停止整个
处理器
组,但我想要的是只停止该组的第一个
处理器
,因为我知道该组的id。
浏览 2
提问于2019-07-02
得票数 0
回答已采纳
1
回答
高性能处理异步任务的
Nifi
处理器
asynchronous
、
apache-nifi
我有一个
Nifi
处理器
,它调用一个外部服务,可能需要几天时间才能返回结果。在此期间,
处理器
可以定期调用Thread.sleep()来释放CPU。问题是,即使在onTrigger()方法中调用Thread.sleep(),
NiFi
处理器
也不会读入和处理新的FlowFiles,因为它正在等待onTrigger()完成。从
NiFi
的角度来看,cpu仍然阻塞着异步调用的完成。 在
NiFi
处理器
的onTrigger()方法中进行异步调用时,
有没有</em
浏览 1
提问于2018-05-09
得票数 0
1
回答
如何分离Apache
NiFi
中不同数据流的日志?
apache-nifi
我使用的是
NiFi
1.9.1,我是这个集群的系统管理员。 在
nifi
-app.log中,我从所有
处理器
组获取日志。
有没有
办法
将日志线分开,以便根据
处理器
组,一组用户只能看到他们感兴趣的那些
处理器
的日志。 谢谢
浏览 28
提问于2019-04-10
得票数 0
回答已采纳
1
回答
Apache
NIFI
:在将文件添加到目录后直接运行Java进程
java
、
apache-nifi
我是Apache
NIFI
的新手。 我想设置一个流,其中有一个文件被放到一个‘热文件夹’中。如果该文件夹检测到有文件被放入其中,则该文件将被放入另一个名为“input”的文件夹中。我的方法是创建一个'GETFILE‘
处理器
来从热文件夹中获取文件。然后创建一个PUTFILE
处理器
,将其放入输入文件夹。所以你可以想象在'GETFILE‘和'PUTFILE’
处理器
之间有一个连接链接。我无法在PUTFILE和EXECUTEPROCESS
处理器
之间创建链接(作为
通知
<
浏览 2
提问于2016-02-05
得票数 2
1
回答
当任何一个
处理器
报告错误时,我如何接受故障警报?
apache
、
apache-nifi
更新:当启动
处理器
组,并离开
Nifi
时,我希望接受失败提醒,以便返回
Nifi
更新
处理器
组。 当任何一个
处理器
报告错误时,我如何接受故障警报?TIA
浏览 1
提问于2019-10-18
得票数 0
1
回答
Apache
处理器
达到启动参数上限
solr
、
apache-nifi
、
data-ingestion
我正在使用Apache
Nifi
中的QuerySolr
处理器
检索超过10000 (这是QuerySolr
处理器
1中定义的上限)的文档列表。在Solr processor中
有没有
办法
绕过这个限制,或者
有没有
办法
检索比定义的上限更多的QuerySolr文档? 1
浏览 8
提问于2019-10-11
得票数 0
1
回答
Apach
Nifi
revert flowfile属性
apache-nifi
在我的
Nifi
1.3.0数据流中,FetchElasticsearchHttp
处理器
将filename属性更改为其在数据库中的对应ID。我想知道
有没有
办法
用一些
Nifi
的内部
处理器
把它改回来。我想过简单地编写自己的脚本来纠正这个问题,但似乎没有
办法
知道它是什么文件,所以我不能只是获取它的名称。
浏览 2
提问于2017-07-09
得票数 0
回答已采纳
2
回答
Apache
Nifi
: Oracle到Mongodb的数据传输
mongodb
、
oracle
、
apache-nifi
我想使用apache
nifi
将数据从oracle传输到MongoDB。Oracle总共有900万条记录。我已经使用QueryDatabaseTable和PutMongoRecord
处理器
创建了
nifi
flow。此流程运行良好,但存在一些性能问题。在启动
nifi
流之后,SplitJson -> PutMongoRecord队列中的记录不断增加。
有没有
办法
降低SplitJson
处理器
放入队列中的记录的速度?
浏览 8
提问于2020-06-29
得票数 0
2
回答
在
NiFi
1.2.0中使用
NiFi
1.5.0
处理器
apache-nifi
正如下面提到的,有一个特定的
处理器
是我感兴趣的,它在1.5.0中有一个相对于1.2.0的额外特性,所以我想使用它。
处理器
名称: QueryDatabaseTable我看有两种方法。上面的
处理器
存储为
nifi
标准的-nar-x.nar-unpack文件。因此,只需从1.5.0中复制Nar并将其放在1.2.0上即可。我不确定在这之后,
nifi
是否会识别这个新的<
浏览 2
提问于2018-03-04
得票数 0
1
回答
需要使用Apache
NiFi
将记录单独发送到Kafka
apache-kafka
、
schema
、
apache-nifi
、
avro
我正在从
nifi
-user日志文件本身读取流/批格式的记录,用于测试场景,并使用Avro
nifi
处理器
转换为ConvertRecord格式,然后使用PublishKafka_2_0
处理器
发布到kafka
有没有
办法
把记录分解成一个单独的实体。我已经尝试过拆分记录
处理器
了,它似乎没有达到预期的效果。
有没有
其他方法来实现它。 --更新
浏览 0
提问于2019-04-08
得票数 2
2
回答
ExcelToCsv
nifi
处理器
中的问题
apache-nifi
我正在使用csv
处理器
的.xlsx文件到ExcelToCsv文件的对话。想要转换一堆.xlsx文件,其中有不同格式的数据到csv。将文件转换为csv后,数据将发生如下更改。https://
nifi
.apache.org/docs/
nifi
-docs/components/org.apache.
nifi
/
nifi
-poi-nar/1.
浏览 5
提问于2020-05-02
得票数 0
1
回答
NiFi
-自动配置最大线程数
docker
、
automation
、
apache-nifi
我在DCOS中的Docker镜像上运行
NiFi
1.3.0。在自动构建之后重新部署映像时,计时器
处理器
的最大线程数重置为10,事件
处理器
的最大线程数重置为5。
有没有
办法
通过
nifi
.properties或在template.xml中配置这些?其他地方吗?用户手册仅引用手动GUI选项。
浏览 67
提问于2018-05-31
得票数 1
回答已采纳
2
回答
如何在apache
nifi
中获取
处理器
的group-id?
apache-nifi
Apache
Nifi
上的另一个问题是,如何获取
处理器
的组id,当您右键单击
处理器
,然后单击stats时,该id也会出现?
有没有
办法
将这个组id值存储为某些属性/流文件内容的一部分。https://{host}:{port}/
nifi
-api/controller/process-groups/{process-group-id}/status?recursive=true
浏览 6
提问于2016-05-26
得票数 0
2
回答
增加来自
NiFi
的CQL的请求超时
cassandra
、
apache-nifi
、
hortonworks-dataflow
我正在使用
NiFi
中的QueryCassandra
处理器
从Cassandra获取数据,但我的查询出现了timedoutexception。当从
处理器
运行CQL查询时,我想增加请求超时。
有没有
办法
做到这一点,否则我将不得不编写一个自定义
处理器
?
浏览 20
提问于2019-07-19
得票数 0
1
回答
如何在
NiFi
处理器
中重新加载外部配置数据
apache-nifi
我有一个自定义的
nifi
处理器
,它使用外部数据进行一些用户控制的配置。我想知道当数据发生更改时,如何向
处理器
发出信号以重新加载数据。我在想,可以发送一个flofile来
通知
处理器
,但我担心在集群环境中,只有一个
处理器
会收到
通知
,而所有其他
处理器
仍将在旧配置上运行。
浏览 9
提问于2020-09-25
得票数 0
1
回答
运行
nifi
流一次,并在完成时
通知
我
apache-nifi
在我的程序中使用rest,我创建了一个
处理器
组,将mongodb集合设置为json文件: 我只想运行一次调度,所以我将“运行计划”设置为10000 sec.Then,当数据流运行一次时,我将停止这个组,我做了一个
通知
处理器
并添加了一个DistributedMapCacheService.But --
通知
处理器
的DistributedMapCacheClientService --
通知
处理器
的DistributedMapCacheClientService只与
n
浏览 0
提问于2018-06-29
得票数 2
回答已采纳
1
回答
NiFi
如何处理突发数据?
apache-nifi
如果提交到
NiFi
的数据不是以稳定的流(而是突发性的)传入的,
NiFi
如何处理它们?它是否使用消息代理来缓冲它们?我还没有在它的文档中看到过类似的东西。
浏览 1
提问于2017-10-27
得票数 0
1
回答
如何为plc创建复杂的
nifi
处理器
?
maven
、
apache-nifi
、
plc
我想创建一个自定义的
nifi
处理器
,这样我就可以读取s7 plc数据。为此,我希望将此项目的java代码:转换为
nifi
处理器
。所以,我已经下载了mvn包类型,就像这个网站管理员告诉我的那样:谢谢!
浏览 1
提问于2019-04-07
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
NIFI1.21.0_Mysql到Mysql增量CDC同步_日期_以及null数据同步处理
Webpack自定义vue文件Loader,Loader执行多次的问题排查与分析!
微信经常延迟接受消息,日常检查这3点,网友:重要消息不再错过
为什么手机用久了会发烫?这4个原因必须了解,让手机不再发烫
安装算量用什么软件?鹏业安装算量软件安装解决方法
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券