apache-nifi 相关问题

无法使用PutElasticsearchHttp连接Nifi到Elasticsearch 8.X版本

我正在尝试一个小型管道，该管道从 postgres 获取数据并将其移动到 elasticsearch。通过使用 PutElasticsearchHttp 处理器，它与 elasticsearch 7.4.0 配合良好。 （都茹...

如何将nifi多个流文件读取到groovy脚本中

我有两个流苍蝇，我想将这两个流文件读取到groovy脚本中，我在groovy中使用以下行来读取流文件内容，但我如何知道我是哪个流文件。 ..

使用 Jolt 转义 json

我们如何将提供的输入转换为所需的输出？ 转换涉及转义字符串并将属性转换为有效的 JSON 格式。但是，任何嵌套属性都...

修改 JOLT 表达式以获取输出 JSON

输入JSON [ { "zone_name": "01 绿色", "zone_type_name": "绿色", “状况”： { “时间戳”...

如何使用 JOLT v0.1.1 转换 JSON 中的日期值

我有这个 JSON 输入： { “实体类型”：“人”， “ID”：24285， “特性”： { “名字”：“齐亚”， “姓氏”：&q...

使用 JOLT v0.1.1 填充 JSON 数组时出现空元素

我正在尝试使用 JOLT v0.1.1 转换从 JSON 输入填充 JSON 数组。但我遇到的问题是，数组在我想要包含的元素之前填充了空元素。 T...

如何在 Apache NiFi 中使用 Jolt 将 JSON 数组转换为嵌套结构？

我正在尝试使用 Apache NiFi 中的 Jolt 将 JSON 数据从输入结构转换为所需的输出结构。这是我的输入 JSON： [ { “位置可用性同步”：{ ...

ListAzureBlobStorage 无法从 ZooKeeper 获取具有 ID 的组件的值

ListAzureBlobStorage 在设置下运行良好： 。 直到它因以下错误而失败，而没有进行任何更改。我已经重新启动nifi并再次重置所有属性。然而，...

使用 JOLT V0.1.1 填充可以包含单个元素的 JSON 数组

我正在研究 NiFi，我想要进行 JOLT V0.1.1 转换，从 JSON 输入生成 JSON 数组。但我遇到的问题是，当 JSON 带有单个电位时

使用 JOLT 表达式转换 JSON

输入JSON { "zone_name" : "01 绿色", "zone_type_name" : "绿色", “状况” ： { "时间戳" : "2024-05-15 10:23:52&qu...

PutHDFS Nifi问题

早上好，我想创建一个从某个 URL 到我的 HDFS 的 Nifi 流。我使用我的个人构建和 Dockerfile 在本地创建了 HDFS 集群，它正在工作，但是当我尝试使用

JOLT 操作根据字符串数组中给出的键过滤结构

我有这个 JSON 输入： { “输入”：{ "a":"值A", "b":"值B", "c":"值C" }, "fieldsToFilterBy":[&quo...

在Cloudera Data Platform CDP公有云中使用Nifi对Kafka进行读/写

Nifi 和 Kafka 现已在 Cloudera Data Platform、CDP 公共云中可用。 Nifi 擅长与一切对话，而 Kafka 是主流消息总线，我只是想知道： 最小的是什么

Apache NiFi：在 UI 上默认删除用户名和密码登录

我目前正在设置 NiFi，我注意到作为版本 1.14.0 版本的一部分，默认情况下我们启用了安全功能，需要用户名和密码才能访问 UI....

如何仅在获取完整数据后调用过程

querydatabasetable --> 从源中获取大约 1GB 数据。 Convertavrotojson ---> 将 avro 从 at 数据转换为 json 格式。 splitjson --> 将 json 流文件拆分为单个 json r...

雅加达邮件无需数据处理程序即可创建附件

我正在尝试将来自 InputStream 的数据附加为 MimeBodyPart 以作为电子邮件附件发送。我了解如何使用 DataSource 和 DataHandler 对象来完成此操作，但是

如何删除/替换nifi流文件内容的最后一行

嗨，我的流程文件如下所示，在执行 sql 查询时，我得到了数据，但我得到了额外的最后一行，所以我想使用 nifi 替换文本处理器删除它，任何帮助都是值得赞赏的。 111 AAA ...

Nifi 在运行时使用 UpdateAttribute 重置计数器变量

有一个通过 SFTP 将文件发送到远程主机的流程。我希望这些文件根据计数器的值进入主机上的不同目录。 所以 PutSFTP 的 RemotePath 值为“/input_data/${cou...

在NiFi上如何区分来自两个不同Kafka的消息？

我有两个不同的应用程序，名为 A1 和 A2。每个应用程序都有自己的 Kafka 服务器。来自这两个 KAFKA 服务器（代理）的消息发送到 NiFi。 每个 Kafka 都有不同的主题名称...

nifi FlowFile 尚未关闭（Groovy 脚本）警告

nifi 术语和流文件处理的新内容。 找到了一种处理传入 xml 并使用 XmlSlurper 解析它的便捷方法，但收到以下针对传入流文件的 GroovyScript 的警告...