apache-nifi 相关问题

如何删除/替换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”...

如何在nifi中拆分流文件json

嗨，只有当我的 json 数组中有多个 json 对象时，我才想将流文件 json arry 拆分为多个 json，如果我的 json 数组中只有一个 json 对象，我不想将其拆分为

如何使用 ISTIO Service Mesh 配置 NIFI？

在浏览器上加载页面时出错：上游连接错误或在标题之前断开/重置。重置原因：协议错误 我已经在 Oracle Kube 上部署了 ISTIO 版本 1.14.0 和 NIFI 版本 1.16.0...

如何测试 Apache NiFi Flow？

我们已经开始使用 NiFi 来完成许多数据管道工作。 Nifi 中具有挑战性的事情之一是对流量变化进行回归测试。 常见的处理方法有哪些

如何使用groovy脚本在apachi nifi流文件中逐行比较两个csv文件

我在apachi nifi中有一次场景，那就是我的流文件中有一个csv数据，我的数据库中有一些csv数据，这些数据与csv流文件有一些不同的数据，现在我想比较

Apache NIFI：无法写入流程内容

我有一个 csv 文件，我使用 GetFile 处理器将其提取到 NiFi，然后使用 ConvertRecord 处理器，没有任何问题，当我将 ExecuteStreamCommand 拖到画布上运行 python 脚本时...