apache-nifi 相关问题

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 的警告...

无法登录Nifi并收到错误消息：访问未知：未找到证书和令牌

我面临着一个持续存在的问题，尽管修改了 nifi.properties 文件中的密钥库和 passwd 设置，但我无法使用自定义证书和反向代理设置登录 Nifi...

将具有相同键值的 Json 分组并使用 Jolt 重命名键

这是在使用 Jolt 对具有相同键值的 Json 进行分组中提出的问题的延续 我想使用 JOLT 对输出 JSON 进行以下更改。您能否帮助获取所需的 JSON

Nifi InvokeHTTP 处理器从 Znuny OTRS 获取 SessionID

我正在尝试使用 Apache Nifi 从 Znuny OTRS 获取门票。我想使用 SessionID 来做到这一点，而不仅仅是用户名和密码。 我不知道如何从 OTRS 安全地获取/创建 SessionID，而不需要...

Nifi 如何识别我数据库中的记录？

注意：我仍在学习/新使用 apache nifi。我之前创建过数据流，现在正在创建真实场景，以了解该工具的有效性以及它是否可以成为插件技术。 高...

NiFi 构建错误

我正在尝试从 https://github.com/apache/nifi 克隆 Apache NiFi 后构建它，但它在 nifi-standard-processors 项目的测试中一直失败。我在

Apache NiFi 之外的依赖项不得使用 SNAPSHOT 版本

我是 NiFi 新手，我正在尝试开发我的第一个定制处理器。 我正在关注有关如何创建一个的文档/教程，我在这里： 为 nifi-proc 生成了 Maven 骨架项目...

如果删除用户名在 v2_communities 之一中匹配，则需要从 v2_communities 中删除该值

输入： { “abc”：“123”， “v2_社区”：[ “社区1”， “社区2” ], "删除用户名": "社区1" } 出来...

如何使用groovy脚本读取nifi中的多个流文件

我有四个（也可能是十个）传入文件，两个流文件具有相同的名称（flowfile1.txt），另一个流文件名称具有相同的名称（flowfile2.txt）。现在我想阅读这些流文件基础...

如何仅在队列变空后才触发下一个处理器

querydatabasetable --> 从源中获取大约 2GB 数据。 Convertavrotojson ---> 将avro从at数据转换为json格式 putdatabaserecord --> 摄取所有 2GB（超过 1 千万

如何仅在另一个处理器执行完毕后才运行一个处理器？

我正在将一个表（200 万行）从 DB2 迁移到 SQL Server。我正在使用下一个流程： ExecuteSQL（从 Db2 表中选择记录）。 SplitAvro（分割记录。我用

如何在属性级别将Json转换为字符串？

在我的 nifi 流程中，我使用 EvaluateJsonPath 处理器读取了一个 json 对象。 json 对象如下所示： [{“id”：“8cbfa4dd-aib4-4f55-b10e-439c9d7f7b4c”，“parent_id”...