Apache NiFi是一个易于使用，功能强大且可靠的分布式系统，用于转换和分发数据。
PutTCP中的压缩 - 在NiFi中的ListenTCPRecord通信
我有一个特殊的用例，我使用PutTCP和ListenTCPRecord在两个NiFi集群之间传输一批JSON消息。有没有办法将压缩应用于...
由于用户“root”@“localhost”的访问被拒绝，Kylo data_ingest Feed作业失败（使用密码：NO）
我已经在Kylo安装目录中为kylo UI上的'data_ingest'设置了一个默认模板 - http：// localhost：8400使用模板我创建了一个Feed来从数据库中获取数据（MySQL），指定...
我有一个“UpdateAttribute”处理器，用于评估JSON文件中的信息。最初，这只会检查客户端是否已更新，语句如下所示：$ {literal（...
Groovy Code中是否有一种方法可以获取ExecuteScript处理器所在的处理器组名称和Groovy代码所在的ExecuteScript处理器的处理器名称。如果是这样，代码将是什么。 ...
我在nifi处理器（executeScript处理器）内部有代码逻辑，它将减少日志文件（在这种情况下，在我的日志文件中我有相同的文本，所以我想删除重复项，我尝试...
我正在从SFTP站点读取CSV文件并使用Nifi将其加载到mysql数据库。我有以下工作流程似乎工作正常。我只是需要一些帮助来弄清楚如何截断...
我有一个集群的NiFi设置（2个节点），当我明确列出RPG URL（http：//：8080 / nifi）中某个节点的IP地址时，它已经启动了远程进程组。问题是......
我正在使用NIFI jsontoavro-> avrotoorc-> puthdfs。但面临以下问题。 1）单个ORC文件正在HDFS上保存。我没有使用任何压缩。 2）当我尝试访问这些文件时，他们是......
我可以使用NIFI在GreenPlum或Postgres sql上运行存储功能吗？如果是，那么我应该使用哪个处理器和配置？
我如何使用Nifi在Greenplum / Postgres SQL上运行存储的函数或过程？
我使用splitText处理器将多语句hql文件拆分为分号上的单个hql语句，然后将它们发送到PutHiveQL处理器'我的问题是需要连接som字段和...
我在Apache NiFi中遇到了InvokeHttp处理器的问题。我想在尝试连接到REST API（通过GET请求）时发生超时时收到消息。根据失败的文件......
Nifi：如何在一个文件中组合14 000个flowfile？
我有1400个具有相同名称的flowFile，我想将它们注册到一个文件中，我已经读过我可以使用mergeContent处理器用于此目的但是当...
我正在尝试使用ListS3，fetchS3object和PutHDFS将数据从S3复制到HDFS。 S3存储桶中的数据结构如下，需要将其复制到具有相同文件夹结构的HDFS（文件夹名称为...
我正在尝试使用以下格式转换JSON：{payload_encrypted：data，timestamp：1469039049}我已经评估了JSON，现在我需要使用我的...中的属性
我有兴趣创建一个在工业PC上运行的软件，连接到某些CNC机床模型，读取数据并将其发送到远程云平台。根据要求，数据必须......
我陷入了NIFI服务拒绝启动的问题。我监控了nifi-app.log，发现它是OutOfMemory错误。我增加了bootstap.conf文件中的内存。但错误......
当verify设置为False时，Python'requests'包 会抛出SSL异常（在Apache Nifi中）
我有一个用于NIFI的ExecuteScript处理器，它运行以下脚本：import requests import json import logging postMap = {'a'：'https：// a / v / 1'，'b'：'https：// b / v / 2'} flowFile = session.get（）...
我正在测试NIFI中的流程，该流程使用REST API检查计数器的特定值。我能够从REST响应中提取正确的值。但是，当我在路线上检查条件时......
Nifi：如何在一个线程（处理器）中对文件进行写入和检查操作？
如何只使一个点（处理器或服务）将写入文件并使其在单线程中工作，在我的情况下，我有像这样的脚本执行工作流程（单线程处理器...
如何使用jolt在json中使用value = current_timestamp添加键值标记
我正在尝试使用jolt对JSON进行JSON转换，我有以下示例JSON想要转换为预期的JSON。你能用jolt库来帮助我。我还想添加一个新的钥匙-...