Apach Nifi revert flowfile属性
Apache Nifi是一个开源的数据集成工具，用于可视化、自动化和管理数据流。它提供了一种简单而强大的方式来移动、转换和处理数据，以及监控数据流的状态。
"revert flowfile属性"是一个不常见的术语，可能是指在Apache Nifi中还原（revert）FlowFile的属性。FlowFile是Nifi中的数据单元，它包含了数据内容以及与数据相关的元数据信息。FlowFile的属性是键值对，用于描述和标识FlowFile的特征和属性。
在Apache Nifi中，可以使用Processors（处理器）来修改FlowFile的属性。如果要还原FlowFile的属性，可以使用UpdateAttribute处理器，将FlowFile的属性设置为之前的值。具体步骤如下：
- 在Nifi界面中，将UpdateAttribute处理器拖动到流程图中。
- 连接UpdateAttribute处理器与之前的处理器或源。
- 双击UpdateAttribute处理器，进入其配置页面。
- 在属性列表中，添加需要还原的属性，并将其值设置为之前的值。
- 保存配置并启动流程。
这样，当FlowFile经过UpdateAttribute处理器时，其属性将被还原为之前的值。
Apache Nifi官方网站：https://nifi.apache.org/
腾讯云相关产品中，可以使用腾讯云流数据开发平台（Tencent Cloud Stream Data Development Platform）来实现类似的数据流处理和管理功能。该平台提供了一套完整的数据集成和处理工具，包括数据流的可视化设计、数据转换、数据存储和监控等功能。
腾讯云流数据开发平台介绍链接：https://cloud.tencent.com/product/sdp
相关·内容
在我的Nifi1.3.0数据流中，FetchElasticsearchHttp处理器将filename属性更改为其在数据库中的对应ID。我想知道有没有办法用一些Nifi的内部处理器把它改回来。
浏览 2提问于2017-07-09得票数 0
回答已采纳
我有一个Nifi Groovy脚本。将字段分配给nifi属性，但如果json值为空，则定义null。如果json值为null，我想要定义属性为空。空属性如下所示；我想喜欢这个；这是我使用的脚本；import java.nio.charset.*if (flowFile == null) {
retur
浏览 15提问于2022-11-26得票数 0
回答已采纳
我在NiFi中使用EvaluateJsonPath处理器来指定一个组合主键，以便将我的JSON数据写入到elasticsearch中。我必须通过连接两个属性来创建一个名为'key‘的属性，比如'attr1’和'attr2‘。在EvaluateJsonPath配置中，我添加了一个属性' key‘，值为'${attr1}${attr2}’(我使用这个键是为了避免elasticsearch中的冗余)。使用EvaluateJsonPath处理器在json记录中连接两个属性<
浏览 0提问于2018-08-13得票数 2
回答已采纳
基本上，我想编写自定义处理器，它可以在处理器停止时在flowFile中发送属性。 if (flowFile == null) { }flowFile = session.putAttribute(flowFile, "ATTRIBUTE_SIGNAL", "start");
浏览 0提问于2018-04-30得票数 1
回答已采纳
FlowFile规模的考虑因素是什么？它会影响I/O吗?如果提供足够的内存，它是否越大越好？因为每个FlowFile的NIFI都会从磁盘持续到内存？特别是对于Kafka Consumer Processor，它包含一个名为Message Demarcator的属性。尤其让我困惑的部分是这个文档https://community.hortonworks.com/questions/21011/how-i-extract-attribute-from-json-fil
浏览 14提问于2019-01-18得票数 0
回答已采纳
1回答
$.id:append('-') & ${id: append ('-')} in JsonPathProcessor不给我任何结果，在Apache中的传入属性末尾添加文本的正确方法是什么？
浏览 3提问于2017-05-16得票数 0
回答已采纳
我已经生成了带有date属性的flowfile，然后我想对我的date进行一些更改：import org.apache.commons.io.IOUtilsimport org.apache.nifi.processor.io.StreamCallback
def date=flowfile.getAttributeflowfile) retu
浏览 6提问于2017-08-10得票数 3
回答已采纳
我需要设计一个包含两个流文件的Nifi结构：
编辑:这里的想法是准备一个邮件营销活动。为此，我需要将所有元数据(在属性中)和html (在内容中)发送给我们的提供者API。
带有可变字段的CSV文件(名称、电子邮件地址、取消订阅链接.)
浏览 0提问于2018-02-19得票数 0
回答已采纳
我在nifi集群中有3个节点。我使用"Partition“将流文件分发到nifi集群中的其他nifi节点。例如，我使用"type"属性来表示"Partition“；FlowFile -> type: B对于此场景，具有相同“与此同时，一款“XY类型”的FlowFile即将面世(第一次)。意味着它以前从未出现过)。
浏览 1提问于2019-01-28得票数 1
回答已采纳
我编写了一个处理xlsx到csv的nifi自定义处理器，在我的代码中，我从xlsx生成了一个类似这样的字符串csv，但我不知道如何将它作为csv发送，而其他处理器，如csv的inferavroschemaresults.isEmpty()){ }flowFile = session.write(flowFile, new Output
浏览 9提问于2019-11-04得票数 1
回答已采纳
我需要从NiFi中执行HTTP，但我不希望/不需要请求来携带所有的FlowFile内容。
是否有办法传递FlowFile的属性，但不传递完整的内容？
浏览 3提问于2017-06-17得票数 3
回答已采纳
我有一个Nifi流，它将获取活动的NameNode，并将NN放入Flow文件属性中。现在，我想在下一个应用程序中使用NN属性，它是一个fetchHDFS处理器。但是它看起来像是队列中的flowFile没有通过FetchHDFS处理器。
更新
我希望动态地更改hdfs路径/ActiveNN等以获取数据，因此所有这些信息都将显示在flowfile属性中。下
浏览 0提问于2021-11-26得票数 0
目标：是通过获取value文件属性在executeScript中使用executeScript在CSV中添加文件名字段值。问题：如何为我传递流文件以获得要包含的属性-- outputstream --写 def __init__(self,flowFile): passif (flowFile<
浏览 10提问于2021-07-17得票数 0
但是，当我试图在UpdateAttribute处理器中设置这些值，然后使用表达式引用访问键和秘密键设置中的属性时，它们似乎没有被设置，put对象调用失败。这两个属性是在UpdateAttribute处理器之前在PutS3Object处理器中设置的。
浏览 2提问于2017-04-26得票数 1
回答已采纳
我目前正在处理一个NiFi流，它需要实现自定义处理器来对csv记录应用转换。由于错误不能用单个线程再现，所以我更多地考虑处理流文件时的一些问题，或者我不知道的NiFi的某些方面。 ...
/&#x
浏览 4提问于2016-09-21得票数 1
回答已采纳
1回答
我想使用nifi加密json中的属性，而不是密钥，因为我想将数据上传到mongodb服务器。有办法这样做吗？Nifi能否重新创建一个json，将键附加到我提取的这个属性上？有更好的方法吗？
浏览 1提问于2016-10-27得票数 2
回答已采纳
但我知道这个错误：
impor
浏览 0提问于2019-07-12得票数 0
回答已采纳
2回答
我试图通过GetHTTP 1.5.0中的NiFi处理器连接到REST端点。我面临的问题是，SSL证书是颁发给域的，但我只能直接访问IP:端口地址(公司防火墙)。
浏览 2提问于2018-05-04得票数 6
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
