Apach Nifi revert flowfile属性

文章/答案/技术大牛

发布

1回答

apache-nifi

在我的Nifi1.3.0数据流中，FetchElasticsearchHttp处理器将filename属性更改为其在数据库中的对应ID。我想知道有没有办法用一些Nifi的内部处理器把它改回来。

浏览 2提问于2017-07-09得票数 0

回答已采纳

2回答

Nifi - Groovy Json脚本定义空属性

groovy、apache-nifi

我有一个Nifi Groovy脚本。将字段分配给nifi属性，但如果json值为空，则定义null。如果json值为null，我想要定义属性为空。空属性如下所示；我想喜欢这个；这是我使用的脚本；import java.nio.charset.*if (flowFile == null) { retur

浏览 15提问于2022-11-26得票数 0

回答已采纳

2回答

Apache NiFi求值JSONPath处理器:用于连接2个属性的JSONPath表达式

apache-nifi、json-path-expression

我在NiFi中使用EvaluateJsonPath处理器来指定一个组合主键，以便将我的JSON数据写入到elasticsearch中。我必须通过连接两个属性来创建一个名为'key‘的属性，比如'attr1’和'attr2‘。在EvaluateJsonPath配置中，我添加了一个属性' key‘，值为'${attr1}${attr2}’(我使用这个键是为了避免elasticsearch中的冗余)。使用EvaluateJsonPath处理器在json记录中连接两个属性<

浏览 0提问于2018-08-13得票数 2

回答已采纳

1回答

NiFi:发送flowFile @OnflowFile文件

java、apache-nifi

基本上，我想编写自定义处理器，它可以在处理器停止时在flowFile中发送属性。 if (flowFile == null) { }flowFile = session.putAttribute(flowFile, "ATTRIBUTE_SIGNAL", "start");

浏览 0提问于2018-04-30得票数 1

回答已采纳

1回答

FlowFile的大小是否会影响I/O

apache-nifi

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回答

Apache附加函数

apache-nifi

$.id:append('-') & ${id: append ('-')} in JsonPathProcessor不给我任何结果，在Apache中的传入属性末尾添加文本的正确方法是什么？

浏览 3提问于2017-05-16得票数 0

回答已采纳

2回答

在apache-nifi中使用groovy

groovy、apache-nifi

我已经生成了带有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

回答已采纳

1回答

如何将两个流文件合并为一个

apache-nifi

我需要设计一个包含两个流文件的Nifi结构：编辑:这里的想法是准备一个邮件营销活动。为此，我需要将所有元数据(在属性中)和html (在内容中)发送给我们的提供者API。带有可变字段的CSV文件(名称、电子邮件地址、取消订阅链接.)

浏览 0提问于2018-02-19得票数 0

回答已采纳

1回答

Nifi“按属性划分”如何将FlowFiles发送到其他Nifi节点？

apache-nifi

我在nifi集群中有3个节点。我使用"Partition“将流文件分发到nifi集群中的其他nifi节点。例如，我使用"type"属性来表示"Partition“；FlowFile -> type: B对于此场景，具有相同“与此同时，一款“XY类型”的FlowFile即将面世(第一次)。意味着它以前从未出现过)。

浏览 1提问于2019-01-28得票数 1

回答已采纳

1回答

如何在apache nifi* writer中设置内容类型csv？*

java、apache-nifi

我编写了一个处理xlsx到csv的nifi自定义处理器，在我的代码中，我从xlsx生成了一个类似这样的字符串csv，但我不知道如何将它作为csv发送，而其他处理器，如csv的inferavroschemaresults.isEmpty()){ }flowFile = session.write(flowFile, new Output

浏览 9提问于2019-11-04得票数 1

回答已采纳

1回答

阻止(或删除) FlowFile内容

apache-nifi

我需要从NiFi中执行HTTP，但我不希望/不需要请求来携带所有的FlowFile内容。是否有办法传递FlowFile的属性，但不传递完整的内容？

浏览 3提问于2017-06-17得票数 3

回答已采纳

1回答

使用ExecuteStreamCommand的Python脚本

python、apache-nifi

此外，我喜欢将数据保存在"NiFi管理“之下的想法。如何

浏览 0提问于2018-03-24得票数 12

回答已采纳

1回答

配置csvReader以使用Apache中的Avro模式注册表时遇到的错误

schema、apache-nifi、avro、csvreader

csvReader属性集：运行Apache-nif

浏览 0提问于2021-07-01得票数 0

回答已采纳

1回答

将Flowfile文件传递给FetchHdfs处理器

apache-nifi

我有一个Nifi流，它将获取活动的NameNode，并将NN放入Flow文件属性中。现在，我想在下一个应用程序中使用NN属性，它是一个fetchHDFS处理器。但是它看起来像是队列中的flowFile没有通过FetchHDFS处理器。更新我希望动态地更改hdfs路径/ActiveNN等以获取数据，因此所有这些信息都将显示在flowfile属性中。下

浏览 0提问于2021-11-26得票数 0

1回答

如何在NiFi中的python类中传递flowfile属性？

apache-nifi

目标：是通过获取value文件属性在executeScript中使用executeScript在CSV中添加文件名字段值。问题：如何为我传递流文件以获得要包含的属性-- outputstream --写 def __init__(self,flowFile): passif (flowFile<

浏览 10提问于2021-07-17得票数 0

1回答

如何配置NiFi* PutS3Object处理器以使用流属性处理S3凭据*

apache-nifi

但是，当我试图在UpdateAttribute处理器中设置这些值，然后使用表达式引用访问键和秘密键设置中的属性时，它们似乎没有被设置，put对象调用失败。这两个属性是在UpdateAttribute处理器之前在PutS3Object处理器中设置的。

浏览 2提问于2017-04-26得票数 1

回答已采纳

1回答

Apache NiFi* - NullPointerException在自定义处理器上设置多个线程。*

java、nullpointerexception、apache-nifi

我目前正在处理一个NiFi流，它需要实现自定义处理器来对csv记录应用转换。由于错误不能用单个线程再现，所以我更多地考虑处理流文件时的一些问题，或者我不知道的NiFi的某些方面。 ... /&#x

浏览 4提问于2016-09-21得票数 1

回答已采纳

1回答

Nifi加密json

json、encryption、apache-nifi

我想使用nifi加密json中的属性，而不是密钥，因为我想将数据上传到mongodb服务器。有办法这样做吗？Nifi能否重新创建一个json，将键附加到我提取的这个属性上？有更好的方法吗？

浏览 1提问于2016-10-27得票数 2

回答已采纳

1回答

如何在DBCPConnectionPoolLookup中使用“InvokeScriptedProcessor”？

groovy、apache-nifi

但我知道这个错误： impor

浏览 0提问于2019-07-12得票数 0

回答已采纳

2回答

SSL上下文服务中的NiFi绕过主机名验证

ssl、apache-nifi、sslcontext、subject-alternative-name

我试图通过GetHTTP 1.5.0中的NiFi处理器连接到REST端点。我面临的问题是，SSL证书是颁发给域的，但我只能直接访问IP:端口地址(公司防火墙)。

浏览 2提问于2018-05-04得票数 6

回答已采纳

点击加载更多