腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
Apache
NiFi
如何
检查
每个
处理器
的
输出
apache-nifi
我是使用
Apache
的
新手,我正在尝试创建一个模板,该模板采用
NiFi
文件并将其转换为一组SQL insert语句。到目前为止,我已经创建了一个采用JSON文件
的
模板,并且已经将其转换为PutSQL。目前没有要连接
的
数据库,但我无法
检查
的
是
输出
。这可以做到吗?我需要
检查
的
是JSON数组是否已转换为数组中
每个
元素
的
插入
浏览 40
提问于2021-07-16
得票数 0
1
回答
Nifi
自定义
处理器
异常
apache-nifi
我使用
的
是
Nifi
0.4.1版本。正在编写自定义代码以将CSV转换为avro格式。我已经创建了类文件,并能够生成nar文件。将nar文件放入lib目录并重新启动
nifi
服务器。当在
nifi
工作区拖动
处理器
时,无法看到为将csv转换为avro而创建
的
类。谢谢,
浏览 4
提问于2016-02-25
得票数 3
1
回答
Apache
NiFi
--它能在
处理器
级别进行扩展吗?
etl
、
apache-nifi
给
Apache
NiFi
的
新手警报!假设有一个2节点集群节点1&节点2。一个简单
的
用例作为示例:如果在集群中
的
节点1上触发了管道,这是否意味着所有10个批仅在节点1中运行?在
每个
处理器
级别的
NiFi
中都有“开箱即用”
的</
浏览 10
提问于2022-11-14
得票数 0
回答已采纳
1
回答
通过
Apache
nifi
将JSON日志文件导入Solr
json
、
solr
、
apache-nifi
我正在尝试读取json日志文件并使用
apache
将其插入到solr集合中,格式如下(一个json对象
nifi
.logfile ){ "@timestamp": "2017-02-18T02:16:50.496+04:00","message": "hello"} 我能够加载该文件,并使用不同
的</
浏览 17
提问于2017-03-15
得票数 0
回答已采纳
1
回答
如何
使用
Apache
Nifi
在多个节点上运行Kafka消费者
处理器
实例
apache-kafka
、
apache-nifi
目前我们使用
Apache
NiFi
通过Kafka consumer消费消息。kafka客户端
的
输出
连接到hive
处理器
。 我正在研究
如何
在
nifi
集群上运行kafka消费者实例。我有3个节点
的
nifi
集群和一个有3个分区
的
kafka主题,我希望kafka消费者能够在
每个
节点上运行,这样
每个
消费者可以从一个主题分区轮询消息。在我启动kafka消费者
处理器
之后,我只能
浏览 3
提问于2019-08-04
得票数 0
1
回答
如何
使用
NiFi
进程会话迁移功能?
java
、
session
、
apache-nifi
我试图在读取流文件
的
同时
输出
流文件。(它在读取完文件
的
一部分而不是整个文件后立即
输出
) 但是,ProcessSession似乎要求在目标
处理器
可以读取所有流文件之前提交它。否则,可以选择将其迁移到另一个
处理器
。
如何
使用迁移功能?更具体地说,我从哪里获得“newOwner”值? 或者有没有人对我原来
的
问题有什么想法?下面是ProcessSession代码:github.com/
apache
/
nifi</em
浏览 12
提问于2020-01-03
得票数 1
1
回答
如何
使用
Apache
Nifi
将数据从HDFS传输到Oracle?
apache-nifi
我是
Nifi
的
新手,正在寻找有关使用
Nifi
处理器
以获得高达100MB/s速度
的
信息。
浏览 29
提问于2020-04-10
得票数 0
回答已采纳
2
回答
ExcelToCsv
nifi
处理器
中
的
问题
apache-nifi
我正在使用csv
处理器
的
.xlsx文件到ExcelToCsv文件
的
对话。想要转换一堆.xlsx文件,其中有不同格式
的
数据到csv。将文件转换为csv后,数据将发生如下更改。https://
nifi
.
apache
.org/docs/
nifi
-docs/components/org.
apache
.<em
浏览 5
提问于2020-05-02
得票数 0
1
回答
用于引用控制器服务
的
多NAR依赖项
maven
、
apache-nifi
我正在开发一个自定义
处理器
,它同时使用DBCPService和RecordReader。 <dependencies> <groupId>org.
apache
.
nifi
</groupId<groupId>org.
apache
浏览 3
提问于2020-09-29
得票数 0
回答已采纳
1
回答
使用ControllerService进行
NiFi
处理器
JUnit测试
java
、
junit
、
apache-nifi
我正在开发一个
NiFi
处理器
,并想用JUnit测试它,但是
处理器
的
一个属性是ControllerService,它是DBCPConnectionPool,但是我不知道
如何
将这个服务添加到JUnit测试中我尝试新建DBCPConnectionPool(),但没有这样命名
的
对象,尽管我已经将所有依赖项添加到我
的
pom文件中,如下所示: <groupId>org.
apache
浏览 34
提问于2019-08-02
得票数 1
1
回答
星星之火会话返回一个错误:
Apache
NiFi
scala
、
apache-spark
、
apache-nifi
、
livy
我们正在尝试使用
NiFi
运行一个spark程序。,我们试图跟踪。 2020-04-13 21:50:49,955 INFO
NiFi
Web 85 org.<em
浏览 10
提问于2020-04-03
得票数 6
1
回答
org.
apache
.
nifi
.record.sink.lookup.RecordSinkServiceLookup
NiFI
:-未能为CONTROLLER_SERVICE CONTROLLER_SERVICE
java
、
maven
、
apache-nifi
我试图在我
的
自定义
处理器
中使用DBCPConnectionPool服务。因此,
如何
在我们
的
自定义
处理器
中使用内置
的
控制器服务(已经在
NiFi
上可用)。当我尝试使用org/
apache
/
nifi
/record/sink/RecordSinkService打包它时,它开始抛出错误为:在执行org.
apache
.
nifi
:
nifi
plu
浏览 0
提问于2021-11-15
得票数 0
1
回答
Apache
Nifi
ConsumeKafka_1_0
处理器
的确切工作原理
apache-kafka
、
kafka-consumer-api
、
apache-nifi
我有
Nifi
集群,Kafka也安装在那里。 创建了一个带有5个分区
的
主题,开始使用带有一个gourp-id
的
主题。这样
每个
分区都会得到唯一
的
消息。现在,我创建了5个ConsumeKafka_1_0
处理器
,目的是在
每个
消费者端获得唯一
的
消息。但只有2个ConsumeKafka_1_0正在使用rest设置为理想
的
所有消息。现在我所做
的
是启动5个命令行Kafka使用者,所发生
的
是,我能够看到所有的分区正在
浏览 2
提问于2018-08-14
得票数 0
1
回答
如何
为自定义
处理器
生成使用文档
apache-nifi
我已经创建了几个自定义
NiFi
处理器
,但是无法获得要生成
的
使用文档。“使用”文档指的是右键单击
处理器
并选择“使用”,这将显示有关该特定
处理器
的
文档。将显示文档面板,但我
的
自定义
处理器
都不存在。我在我
的
自定义
处理器
类上使用了几个
NiFi
文档标记,包括几个读/写属性。代码编译和单元测试没有任何问题。构建报告 为NAR中
的
NiFi
扩展生成文档.该文件应该存在
浏览 1
提问于2019-08-16
得票数 0
1
回答
Nifi
处理器
组级资源消耗
java
、
jmx
、
apache-nifi
在当前
的
项目设置中,我们看到
nifi
级别的资源消耗和模式使用:是否有人实现了进程组级资源监视(内存、CPU我找不到用API实现它
的
任何方法。
浏览 0
提问于2018-03-28
得票数 0
回答已采纳
1
回答
将现有的ETL迁移到
NiFi
:我应该选择什么
处理器
?
apache-nifi
我们有现有的ETL管道,探索将管道迁移到
NiFi
的
可能性。 我们
的
流水线包含用python/scala编写
的
作业,并进行大量
的
摄取/转换。什么样
的
处理器
NiFi
允许我把python/scala代码放进去? 非常感谢。
浏览 11
提问于2019-01-05
得票数 0
回答已采纳
1
回答
通过自定义
NiFi
处理器
使用GCP控制器服务
java
、
apache-nifi
我已经编写了一个用于在BigQuery上执行某些任务
的
自定义
NiFi
处理器
。我希望能够重用与
NiFi
捆绑在一起
的
GCP凭据提供者控制器服务,以用于身份验证。这个是可能
的
吗?我尝试将
nifi
-gcp-processors maven依赖项添加到我
的
项目中,它成功地构建了,但是当我尝试使用我
的
nar启动
NiFi
时,它失败了,并显示以下错误消息。: org.
apache
.
nifi
.pro
浏览 4
提问于2017-12-14
得票数 0
回答已采纳
1
回答
在
Nifi
中,带有Hive数据库连接池服务
的
自定义
处理器
不能工作。
java
、
apache-nifi
我正在开发带有hive数据库连接池服务
的
自定义
处理器
。在pom文件中添加必要
的
依赖项,并在自定义
处理器
文件夹中添加必要
的
文件夹。我已经创建了类文件,并能够生成nar文件。将nar文件放入lib目录并重新启动
nifi
服务器。一切看起来都很好。但是,服务没有显示在数据库连接下拉框中。相反,它显示连接id,但每次服务创建时,单击控制器部分中
的
"create“。对于其他
处理器
,它似乎工作正常。谢谢
浏览 2
提问于2017-02-10
得票数 1
回答已采纳
1
回答
如何
在Ni-Fi中重命名相同位置
的
文件
apache-nifi
我
的
sftp路径中有一些文件,我想使用Ni-Fi重命名相同位置
的
文件。 请推荐适合我情况
的
nifi
制程。 提前谢谢。
浏览 26
提问于2020-01-02
得票数 0
1
回答
Nifi
调用http
如何
获取值并在post数据期间添加为标头
apache-nifi
我有一个
NiFi
流,它需要将数据发布到其他服务器,在发布之前,它需要从我
的
内部服务器或
Nifi
分布式缓存中获取一个值。下面是我正在尝试
的
流程,所有的绿色
处理器
都是我能做
的
,但是我只能获取值并添加到invoke http头中。我可以让我们实现这一目标的其他过程是什么。 ?
浏览 100
提问于2020-01-22
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache NiFi用户指南-数据流的命令和控制
大数据流处理:Flume、Kafka和NiFi对比
Apache NiFi介绍及使用体验
10分钟了解Apache Nifi在物联网的使用
Apache NiFi用户指南-数据流版本控制
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券