腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
2
回答
Apache
:
将
NiFi
行
合
并到
Json
中
我有一个SQL数据库,我提取了一些
行
,将它们转换成
Json
来提供一个MongoDB。我被转换步骤卡住了。我尝试过这个流程: ? 进程在MergeRecord处理器上停止了,我不知道为什么。220429 100001379620 1801300002 10 220429 100001 到这个
json
"219454", "siteCode" : "014075" }
浏览 67
提问于2019-03-21
得票数 0
回答已采纳
2
回答
如何使用流创建正在运行的
nifi
docker镜像
、
我启动了一个
apache
/
nifi
容器,构建并配置了一个流。我不清楚是什么文件(nar、xml等)需要对用户要运行的映像可用。
浏览 5
提问于2020-09-22
得票数 1
2
回答
Apache
NiFi
/Cassandra - PutCassandraRecord无法转换为记录对象
、
我正在尝试使用
NiFi
的PutCassandraRecord处理器
将
一些
JSON
记录插入到Cassandra DB
中
。我试图
将
时间戳类型插入到Cassandra
中
,但是
NiFi
抱怨输入字符串"2019-02-02T08:00:00.000“的NumberFormatException。schema: org.
apache
.
nifi
.serialization.MalformedRecordException: Success
浏览 8
提问于2019-05-14
得票数 1
1
回答
为什么我的
NiFi
Nar没有出现在处理器列表
中
?
刚刚从教程
中
创建了我的第一个NAR,将其放在/lib文件
中
并重新启动了
NiFi
。处理器在日志
中
显示为已加载,但不在处理器列表
中
显示。有什么想法吗?教程: @Tags({"
JSON
", "
NIFI
ROCKS"})2017-07-06 19:34:06,200 INFO
浏览 67
提问于2017-07-07
得票数 3
回答已采纳
1
回答
使用where条件更新表的
Nifi
PutDatabaseRecord
如何使用PutDatabaseRecord只更新名为student的表
中
的三列,该表有几列?我正在尝试使用
NiFi
实现以下where子句查询。因此,v1、v2、v3、v4将是
json
数组 SELECT class,name,section,id FROM registration where registerd_on='20210530
浏览 119
提问于2021-10-15
得票数 0
回答已采纳
1
回答
在
nifi
中
,自定义处理器正在抛出未指定异常的传输关系。
、
在
nifi
中
,我正在创建一个自定义处理器,它读取多行csv数据,并将每一
行
转换为
json
并发送。;import org.
apache
.commons.io.IOUtils;import org.
apache
.<em
浏览 0
提问于2019-05-11
得票数 3
回答已采纳
2
回答
设置
nifi
.web.http.host后无法访问
Nifi
、
、
、
我对
Nifi
有个问题。当我设置
nifi
.web.http.host=luan 01时,我无法通过公共IP访问浏览器上的
Nifi
,例如:、。我只能通过主机名访问
Nifi
。你有什么解决办法吗?非常感谢。
浏览 2
提问于2019-06-29
得票数 1
回答已采纳
1
回答
可以连接到本地主机:8443-
Apache
NiFi
我正在尝试在我的笔记本电脑上运行
Apache
NiFi
。我可以启动run-
nifi
.bat,但是当我尝试访问http://localhost:8443/时。我得到一个错误在chrome“网站无法到达” 在同一台笔记本电脑上,我正在访问运行在亚马逊网络服务上的不同
NiFi
实例。使用不同的端口(生产)。 系统: Windows10 请帮助连接
浏览 63
提问于2021-11-23
得票数 0
1
回答
Apache
附加函数
$.id:append('-') & ${id: append ('-')} in JsonPathProcessor不给我任何结果,在
Apache
中
的传入属性末尾添加文本的正确方法是什么?
浏览 3
提问于2017-05-16
得票数 0
回答已采纳
1
回答
星星之火会话返回一个错误:
Apache
NiFi
、
、
、
我们正在尝试使用
NiFi
运行一个spark程序。,我们试图跟踪。val gdpRDD = gdpDF.rddLivyController被信任为127.0.0.1当我们运行处理器时,我们会得到以下错误: Spark会话返回一个错误,
将
输出
JSON
对象作为流文件内容发送到失
浏览 10
提问于2020-04-03
得票数 6
1
回答
apache
nifi
无状态-无法设置控制器服务的参数(DBCPConnectionPool 1.10.0)
我按照
NiFi
1.10 stateless guildeline在mysql
中
创建了一个执行sql的简单进程组。我已经
将
db控制器服务的必要参数放到了参数上下文中。 ? ? 它在
nifi
canvas
中
运行良好。然后将其添加到注册表并准备一个
json
parm文件:stateless simpledb.
json
{ "registryUrl": "http://localhost:18080&qu
浏览 76
提问于2019-12-14
得票数 3
1
回答
Nifi
自定义处理器异常
我使用的是
Nifi
0.4.1版本。正在编写自定义代码以
将
CSV转换为avro格式。我已经创建了类文件,并能够生成nar文件。
将
nar文件放入lib目录并重新启动
nifi
服务器。当在
nifi
工作区拖动处理器时,无法看到为
将
csv转换为avro而创建的类。谢谢,
浏览 4
提问于2016-02-25
得票数 3
1
回答
在hdfs
中
存储小文件并在
Nifi
Flow
中
对其进行归档
、
、
、
、
场景:我正在使用
NiFi
来阅读卡夫卡主题中的消息,这些都是非常小的。 要求:
将
这些原始数据消息存储在HDFS
中
(用于重放功能),...before对其进行进一步处理。这是我可以通过
Nifi
做的事情吗?“har命令看起来像是命令行的东西,而不是我可以通过
Nifi
执行的东西?我很想知道一个解决方案,可以满足我的要求,而不会因为文件太小而导致HDFS宕机。 Ginil
浏览 11
提问于2020-08-19
得票数 0
回答已采纳
1
回答
如何在给出多个对象时提供抖动输入
、
、
如何
将
转换应用于具有以下格式记录的
json
文件(不是数组,而是多个对象)。我想提供一个具有以下输入格式的文件,并在应用transfornation.Want后将其保存在某个文件夹
中
。
浏览 2
提问于2020-04-27
得票数 0
1
回答
Nifi
为前一天合并的
json
文件在HDFS路径上移动文件
、
、
、
、
我需要将前一天处理和合并的
json
文件移动到新的hdfs路径
中
。要求是递归地搜索未处理的文件并移动挂起的未处理的文件。Path 1 -> /data/
nifi
/working/2019/10/source_2019_10_15.
json
-每日处理的文件
将
合
并到
此路径下,并按天添加。路径2 -> /data/
nifi
/incoming/ --如果文件夹不存在,
浏览 1
提问于2019-10-17
得票数 0
2
回答
在
Apache
NiFi
中
读取UCS-2 LE BOM编码文件时遇到的问题
、
、
、
在
Apache
中
,我试图读取一个
将
编码为
NiFi
的文本文件,然后尝试将其转换为
JSON
。但是
Apache
NiFi
正在考虑将其作为一条单行。有人知道如何使用
Apache
将该文件转换为UTF-8吗?
浏览 15
提问于2020-06-15
得票数 3
回答已采纳
1
回答
NiFi
:从文件
中
删除固定数量的头
行
、
、
、
我正在处理一个文件,我希望删除(trim)第一个X头
行
,以只保留数据,可能的话,避免使用正则表达式。 谢谢
浏览 3
提问于2017-01-13
得票数 7
回答已采纳
1
回答
从请求在
Apache
中
记录
NiFi
有效负载
、
、
我是
Apache
的新手,我开发了一个通过HTTP请求
将
NiFi
数据发送到
NiFi
端点的应用程序。在
Apache
NiFi
中
,我有一个HandleHTTPRequest处理器连接到PutFile处理器,然后连接到HandleHTTPResponse处理器。来自
JSON
服务的响应代码和HTTP运行正常,但我正在努力确保正确发送
NiFi
有效负载。在HTTPRequest处理程序
中
启用了Post。然而,它生成的唯一文件是空白
浏览 9
提问于2016-07-06
得票数 3
1
回答
使用ControllerService进行
NiFi
处理器JUnit测试
、
、
我正在开发一个
NiFi
处理器,并想用JUnit测试它,但是处理器的一个属性是ControllerService,它是DBCPConnectionPool,但是我不知道如何
将
这个服务添加到JUnit测试
中
我尝试新建DBCPConnectionPool(),但没有这样命名的对象,尽管我已经
将
所有依赖项添加到我的pom文件
中
,如下所示: <groupId>org.
apache
.
nifi
<
浏览 34
提问于2019-08-02
得票数 1
1
回答
运行实例化
NiFi
接收器的Spark应用程序时出现依赖项错误
、
、
、
、
+= "org.
apache
.
nifi
" % "
nifi
-site-to-site-client" % "0.7.0"import org.
apache
.
nifi
.spark._ import org.
apache
.
nifi
.re
浏览 4
提问于2016-07-19
得票数 2
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
将 Excel 表格中每三行合并到一个单元格中,用“、”隔开
如果 Excel 版本够高,不妨用这个函数将每 n 行合并到一个单元格中
Apache NiFi介绍及使用体验
大数据流处理:Flume、Kafka和NiFi对比
NIFI1.21.0_Mysql到Mysql增量CDC同步_日期_以及null数据同步处理
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券