腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
为什么
要
克隆
Flowfile
?
apache-nifi
我想知道
为什么
一些处理器在将流文件路由到下一个处理器之前
克隆
流文件。例如,在将流文件传递给ContentAvrotoORC processor之前,QueryDatabaseTable processor总是先
克隆
它。
为什么
需要
克隆
Flowfile
?
浏览 11
提问于2019-05-21
得票数 1
回答已采纳
1
回答
nifi是否支持将单个流文件传输到处理器中的多个关系?
minify
、
apache-nifi
示例代码:session.transfer(
flowFile
, REL_SUCCESS_2);
浏览 0
提问于2018-04-02
得票数 3
回答已采纳
1
回答
惩罚流文件会导致以下处理器累积任务/时间
apache-nifi
因此,我使用的ExecuteScript处理器具有以下代码:
flowFile
= session.get() session.penalize(
flowFile
) session.transfer(
flowFile
, REL_SUCCESS) 它只是在一段时间内惩罚流文件。这一切
为什么
要
发生?流文件是否会被送入UpdateAttribute处理器,它会识别出流文件受到了惩罚,从而导致处理器执行一些工作?这有什么值得担心的吗?
浏览 16
提问于2019-01-30
得票数 0
1
回答
NiFI“找不到流文件内容”
apache-nifi
在尝试修改传入
flowFile
的
克隆
时,我正在使用nifi 1.6并得到以下错误: 我已经为这个处理器创建了单元测试,但是它们在这两种情况下都不会失败。这
浏览 0
提问于2018-12-06
得票数 0
回答已采纳
2
回答
使用executescript将文件内容加载到nifi属性中
groovy
、
apache-nifi
这就是我所得到的:if (
flowFile
!= null) { def message = "Bearer " + token session.
浏览 2
提问于2019-07-30
得票数 2
回答已采纳
1
回答
NiFi-1.0 - content_repo &
flowfile
_repo
apache-nifi
对于5GB的文件,
flowfile
_repo (同时处理)提高到24 GB,content_repo上升到18 GB。content_repo最大值18 GB 有没有一种方法可以预测我需要多少空间来处理N个文件?
为什么
要
占用这么多空间?
浏览 3
提问于2016-12-19
得票数 1
回答已采纳
1
回答
当PutSQL失败时发送电子邮件
apache-nifi
我想在PutSQL失败时发送邮件,PutSQL的Rollback on Failure=true,因为源代码不支持PutSQL失败时发送邮件,所以我添加了REL_ALERT关系,我添加了三行代码在PutSQL失败时发送邮件,但都不起作用。
浏览 2
提问于2019-05-30
得票数 0
2
回答
Nifi自定义处理器如何为redis获取db连接并重用连接
redis
、
apache-nifi
我不明白
为什么
钥匙会被删除。下面是redis地理空间数据的自定义处理器代码。= session.putAttribute(
flowFile
, "msg", "------------>if block inside try"); session.tran
浏览 3
提问于2019-07-13
得票数 0
回答已采纳
1
回答
如何将两个流文件合并为一个
apache-nifi
HTML模板(其路径随元数据而来) 到目前为止,我有一个能够获取所有3个文件的结构,将前两个文件集成在一系列流文件中,这些流文件代表
要
发送的每一封电子邮件。
浏览 0
提问于2018-02-19
得票数 0
回答已采纳
1
回答
如何在为Nifi编写流服务时解决Java的空指针异常?
java
、
python
、
apache-kafka
、
apache-nifi
text = IOUtils.toString(inputStream, StandardCharsets.UTF_8)if (
flowFile
!= None):
flowFile
= session.putAttribute(
flowFile
,"
浏览 2
提问于2018-05-17
得票数 0
回答已采纳
2
回答
如何在flowjs中传递flow.upload上的参数
angularjs
、
flow-js
我需要传递参数,这些参数对于我使用flowobj.opts.query的每个文件都是不同的,但这会添加到所有文件中。每次上传文件的参数应不同 file.flowObj.opts.query[file.DocumentExtension.concat("-DocumentExte
浏览 10
提问于2015-04-30
得票数 0
1
回答
Kafka处理器不会保留
flowfile
的属性状态
apache-nifi
、
apache-minifi
当我看到下面的处理器源代码时,我发现它已经从记录中读取了属性,并在流文件中写入了相同的属性,那么
为什么
这些在流文件中不可用呢?
flowFile
= session.create();
flowFile
= session.write(
flowFile
, out -> { out.write
浏览 11
提问于2019-04-09
得票数 0
回答已采纳
2
回答
将Nifi属性值拆分为多个属性
java
、
split
、
attributes
、
apache-nifi
我有一个使用GetFile处理器获得的文件。我想将这个值为"ABC_gh_1245_ty.csv“的”文件名“属性拆分成多个属性ATTR2 = "gh"ATTR4 = "ty.csv"我搜索并找到了这个自定义处理器:
浏览 1
提问于2019-01-04
得票数 2
回答已采纳
1
回答
Nifi自定义处理器如何在内容或属性中写入结果
java
、
apache-nifi
、
processor
但我不知道如何在
Flowfile
内容或属性中显示结果。在输入值1和输入值2属性中添加值之后,然后运行处理器,
Flowfile
为空。
flowFile
= session.get(); return; int=session.write(
flowFile
, new StreamCallback() { public
浏览 49
提问于2021-01-26
得票数 0
回答已采纳
1
回答
NiFi处理器的任务计数很高,原因是什么?
apache-nifi
、
kylo
org.apache.nifi.annotation.lifecycle.OnScheduled;import org.apache.nifi.
flowfile
.
FlowFile
flowFile
= session.get(); if (
flowFile
!= session.putAttribute(
flowFile
, "_wait_state", &quo
浏览 2
提问于2018-08-17
得票数 1
回答已采纳
1
回答
EvaluateJsonPath无法返回标量
json
、
apache-nifi
、
jsonpath
我试图从JSON中提取一个值到
flowfile
-attribute.当我运行EvaluateJsonPath处理器时,我会得到一个错误声明 "Unable to get a scalar value for
为什么
?我能做些什么来解决这个问题?
浏览 0
提问于2018-10-23
得票数 6
回答已采纳
2
回答
证明在Nifi上XML格式良好
xml
、
apache-nifi
、
well-formed
我试图证明我的XML在Nifi上的格式很好。有人能得到一些帮助吗?非常感谢
浏览 2
提问于2018-02-28
得票数 2
回答已采纳
1
回答
Python / NiFi: ExecuteScript python,将UTF-16文本文件转换为UTF-8
python
、
utf-8
、
apache-nifi
迄今为止:if not flowFileList.isEmpty(): flowFileList.decode("utf-16").encode("utf-8") 我觉得这应该是一个相当容易的操作
浏览 0
提问于2018-12-10
得票数 0
回答已采纳
2
回答
如何在GetDynamoDB处理器中设置Json文档属性
json
、
amazon-web-services
、
amazon-dynamodb
、
apache-nifi
我正在使用nifi中的DynamoDB处理器从GetDynamoDB中获取数据,除了Json文档属性之外,我还提供了所有强制字段,我不知道在该字段中设置什么。 输入数据:"ProductCatalog": [ "PutRequest": { "Id": { },
浏览 2
提问于2017-08-22
得票数 1
1
回答
geoIpEnrich处理器NiFi
apache-nifi
我正在尝试使用geoEnrichIP处理器作为nifi流的一部分。我试图跟踪文档而没有运气。ConvertRecord(Json) -> geoEnrichIP如何正确引用host_address的ip地址名以丰富地理位置数据?
浏览 7
提问于2021-09-22
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
FM十万个为什么:克隆猴来了,克隆“你”还远吗?
Rocket高调重回印尼,是否要“克隆”Lazada?
网站为什么要更新 要改版?
为什么要创业
为什么要创业?
热门
标签
更多标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
活动推荐
运营活动
广告
关闭
领券