腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
用于jsonpath的
Nifi
表达式语言-
字符
串操作,拆分
我想
使用
Nifi
操作json
中
两个属性的值。我不知道如何在
Nifi
的EvaluateJsonPath
处理器
中
使用
哪些功能。
ReplaceText
处理器
或EvaluateJsonPath。如果我
使用
ReplaceText
处理器
,我需要
使用
这个
处理器
中
的一些。我想
一次
使用
多个
替换
浏览 3
提问于2019-12-01
得票数 0
2
回答
nifi
将键值对附加到json流文件。
如何将键/值对附加到
Nifi
中
的json流文件。我尝试了
使用
替换
策略作为
replaceText
的append
处理器
,但是键/值对
不能
正确地插入到JSON
中
。
浏览 0
提问于2018-10-10
得票数 1
回答已采纳
1
回答
必须从
NIFI
数据流
中
的文本文件
中
删除unicode NEL。
我需要从
NIFI
数据流
中
的流文件
中
删除unicode char NEL,直到现在我已经
使用
了
replacetext
处理器
来清除数据,但是如何从
replacetext
处理器
中
搜索unicode
字符
串呢?
浏览 4
提问于2017-06-12
得票数 2
回答已采纳
1
回答
将
NiFi
中
的流文件的文件名附加到CSV文件
首先,我
使用
listFile
处理器
列出特定映射中的所有文件。然后,我想将
NiFi
中
的流文件的${filename}附加到外部文件example.csv。我想过
在
Python中
使用
ExecuteScript,但不知道怎么做。
使用
两个列表
处理器
,一个用于映射,另一个用于example.csv文件。用于将文本
替换
为${filename}、mergeContent和putFile(replace example.cs
浏览 2
提问于2018-06-08
得票数 0
1
回答
Nifi
处理器
没有正确解析JSON
、
、
我
使用
EvaluateJsonPath从JSON中提取一个特定的值。我正在
使用
折叠的JSONPath表达式:这是我
在
JSONPath上调用的JSON文档: {"data"path":["SOURCE_ADLS_NIELSEN_DEPLETION_UAT"],"tag&q
浏览 3
提问于2018-09-24
得票数 2
回答已采纳
1
回答
我想
使用
nifi
将文本转换成JSON格式
我一直试图
使用
NIFI
中
的
replacetext
处理器
将我的整数和
字符
串值转换为JSON格式。但我正面临正则表达式的问题。有人能给我一个搜索值和
替换
值的正则表达式吗?Sensor_id:2.4,locationIP:2.2,Sensor_value:A}{Sensor_id:2.4,locationIP:2.2,Sensor_value:"A"}
处理器
配置
浏览 4
提问于2020-01-28
得票数 0
回答已采纳
1
回答
在
NiFi
中
,
不能
使用
ReplaceText
处理器
一次
替换
多个
字符
在
合并之后,我得到的结果是: {"tag":"a","bag":"b"}{"tag":"c","bag":"d"} 我希望
在
ReplaceText
处理器
之后是这样的: {"tag":"a","bag":"b"},{"tag":"c","b
浏览 157
提问于2020-07-21
得票数 0
1
回答
如何
使用
Rest更新
ReplaceText
处理器
中
的“
替换
值”?
我需要知道如何
使用
Rest更新
nifi
处理器
中
的值。例如:我
使用
了下面的
处理器
结构 FileLocation(GetFile). validation(ExtractText).ReplacementValue(
ReplaceText<
浏览 1
提问于2016-11-02
得票数 0
回答已采纳
1
回答
apache
nifi
中
可能出现的场景
、
、
我正在努力理解apache
在
hdfs中保存文件,并有各种不同的场景可供
使用
。请让我知道每一种方法的可行性,并作出解释。对于每一种情况,我几乎不加理解。 我们是否可以将列值
替换
为另一个文本?我已经检查了
replaceText<
浏览 2
提问于2016-11-08
得票数 0
1
回答
生成表获取SQL SERVER 2016时出现的问题
我试图从Server中提取数据,并
使用
generate表fetch。当我
使用
MYSQL数据库而不是Server进行相同的生成表提取时,它就像预期的那样工作。我正在
使用
的
Nifi
版本- 1.5这是我的流量。编辑:
浏览 3
提问于2018-03-13
得票数 0
回答已采纳
2
回答
ReplaceText
处理器
配置
、
什么是适当的配置来做以下工作; 基本上我需要清理逃脱的JSON。
浏览 2
提问于2016-04-24
得票数 1
1
回答
如何在
NiFi
表达式语言中
使用
正则表达式捕获组变量?
我正在尝试
使用
NiFi
替换
文本文件中所有行的日期格式。该文件如下所示: ABCDE,20200619,23.8...我正在尝试
使用
ReplaceText
处理器
将20200619更改为2020-06-19。问题是当我尝试
使用
表达式语言和:substring函数时。Error 看起来表达式语言
不能
访问我的$1变量。这是我的
处理器
:
NiFi
Processor
浏览 19
提问于2020-06-22
得票数 3
回答已采纳
2
回答
使用
NIFI
解析来自API的odata4时出错
、
、
我正在
使用
Microsoft来查询Azure应用程序,oauth和request没有问题。当我尝试
使用
inferAvroSchema进行解析时,我就可以开始处理它,从而引发“非法初始
字符
:@odata.etag”这个错误。我尝试
在
结果中
使用
EvaluateJsonPath,请求为$.@odata.context创建一个属性,但它也找不到该项,我确信它是关于@的。我也可以将输入流的所有@
替换
为另一个
字符
,但不知道这是否有意义。 我觉得我没有
使用
正确的方法
浏览 11
提问于2019-11-10
得票数 1
回答已采纳
1
回答
如何
使用
apache
nifi
将
多个
json文件加载到具有正确映射的
多个
hive表
中
?
、
、
、
我需要
使用
apache
nifi
将基于表名的
多个
csv文件摄取到它们各自的配置单元表
中
。源json文件
中
的table_address数据应该转到配置单元
中
的table_address,其他表也是如此。简而言之,需要将源json文件
中
的记录分离到
多个
tablename.csv格式的csv文件
中
,并将其加载到各自的hive表
中
。我
使用
的
处理器
消耗kafka -> splitjso
浏览 6
提问于2019-04-10
得票数 0
1
回答
使用
Apache-
NiFi
从标题行csv
中
删除第一个
字符
和逗号分隔符
、
我是Apache-
Nifi
话题的新手。我有一个有价值的csv:a | Mr | 391我
使用
replaceText
处理器
来确保标题行,"#"作为
替换
值,
替换
策略然后,我
使用
routetext获得配置的标题行: Grouping正则表达式:(.*?),.*以及名为header line的新属性,其值为#。这些过程结果是:"#id,title,value 我想从
浏览 16
提问于2016-09-22
得票数 1
回答已采纳
2
回答
如何提高CSV数据
在
SQL Server
中
的处理速度?
、
、
我
使用
了
Nifi
-0.6.1与GetFile+SplitText+
ReplaceText
处理器
的组合来拆分具有30 to (30万行)的csv数据。
在
SpliText +
替换
文本
中
,将数据拆分为Json需要花费25分钟。我
在
处理器
中
尝试过并发任务选项。当时它的cpu
使用
率达到了100%。 如何更
浏览 9
提问于2016-10-14
得票数 1
回答已采纳
1
回答
NiFi
ReplaceText
:
在
特定标记之间删除所有xml标记
、
、
我想去掉<TXT>和</TXT>之间的所有标记,以便在
NiFi
中生成一个原始文本标记,这样原始文本读起来就像一个句子。我
在
ReplaceText
处理器
中
尝试了
NiFi
中
的regex模式,但是这个过程失败了--尽管它捕获了regex101.com上完整的txt部分。我做错了什么?客户端更愿意
使用
内置的
NiFi
处理器
来完成这一任务,而不是实现脚本。<TXT.*>
浏览 1
提问于2019-03-08
得票数 0
1
回答
hdfs中小文件瓶颈的解决方案
、
、
、
我
在
hdfs中有数十万个小csv文件。
在
将它们合并到单个数据文件之前,我需要单独向每个文件添加一个id (否则在合并
中
不可能区分不同文件
中
的数据)。目前,我依靠纱线来分发我创建的进程,这些进程将id添加到每个文件
中
,并转换为拼花格式。我发现,无论我如何调优集群(大小/executor/内存),带宽都限制
在
2000-3000个文件/h。fLogRaw.withColumn('id', F.lit(logId)) fLog.write
浏览 1
提问于2018-12-06
得票数 0
回答已采纳
1
回答
使用
Apache将JSON行转换为JSON数组
、
、
、
、
foo" : "abc", "bar" : "def" }{"foo" : "ghi", "bar" : "jkl", "name" : "The Dude"}[{"foo" : "abc", "bar&
浏览 5
提问于2018-02-14
得票数 1
回答已采纳
1
回答
NiFi
:准备(orAppend)流文件中所有记录的行号
我
使用
的是
NiFi
1.9.2a,b,cg,h,i1,a,b,c3,g,h,i通过
使用
带有属性的
ReplaceText
处理器
,我可以实现以下目标: Search Value : (?表达式语言指南,“计数器在所有
浏览 1
提问于2021-09-09
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
Apache NiFi用户指南-数据流版本控制
Apache NiFi用户指南-数据流的命令和控制
大数据流处理:Flume、Kafka和NiFi对比
20个常用的JavaScript字符串方法
Apache NiFi介绍及使用体验
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券