apache-nifi 相关问题

如何在nifi中简单组合流文件？

假设我有一个处理器生成的 100 个流文件，每个文件都包含不同的行。我想要一个包含 100 行的新流文件。我怎样才能做到这一点？ 我尝试过 MergeCont...

使用 Nifi JoltTransformJson 转换数组中的 JSON 对象

我在Nifi中使用JOLTTransformJson处理器。 我的Json输入格式有以下4种： [ { “一”：“1” } ] 或者 [ { “一”：“1”， &

NiFi - 将 JSON 字符串转换为有效的 JSON

使用UpdateRecord，我尝试将json字符串转换为有效的json： 输入： { "用户" : "{\"id\":\"1\",\"name\":\"TEST\"}" } 当前...

Nifi 处理器基于 cron 的调度

这是我尝试过的语法 0 30 0 * * ？或 0 30 1 * * ?，应分别在午夜 12:30 或 1:30 运行。 另外，我厌倦了每 20 分钟在 NiFi 中使用 cron 运行一次流程，...

如何配置 OAuth 处理器/控制器服务以通过客户端凭据对安全 REST API 进行身份验证从 Apache Nifi 获取访问令牌

如何在 Apache Nifi 中配置 OAuth 2.0 处理器/控制器服务，以使用 StandardOauth2AccessTokenProvider 和客户端凭据对安全 REST API 进行身份验证 尝试了我所做的一切...

使用文件内容更新字符串值

传入的 csv 文件具有以下架构： 纬度；经度 90.232；24.244 我需要通过使用新字段“json”更新传入架构来生成流文件。 预计结果...

Apache NiFi 2.0.0 中缺少 PutHDFS 处理器

我使用的是 Apache NiFi 2.0.0，不幸的是它不包括 PutHDFS 处理器。我的项目需要这个版本的 NiFi，因为它具有与 Python 脚本的集成功能，所以升级...

Apache Nifi：PutHDFS 处理器问题 - PutHDFS 无法写入 HDFS java.lang.NoClassDefFoundError：org/apache/hadoop/conf/Configurable

我正在使用 Apache NIFI 1.28 版本，我正在尝试创建一个简约的数据流，我在其中生成数据并希望在 HDP（Hortonworks 数据平台）2.5.0 中摄取 HDFS，我正在...

使用 JOLT 将当地时间转换为 JSON 格式的 GMT

我有一个 JSON 输入，我使用 JOLT 表示法将其转换为另一个 JSON。 我有需要保存为键值对的措施，站名和站号合并为一个字段和日期字段

属性匹配多个子字符串

我正在寻找一个 nifi 属性并将其与多个子字符串匹配。为此，需要将子字符串保存到外部文件，因为它们数量众多并且需要轻松更新...

如何将`nifi.properties`文件位置从`/opt/nifi/nifi-current/conf/`更改为其他位置

我正在尝试做的事情： 我正在尝试将 nifi 作为 kubernetes 中的单个 pod statefulset 运行，并将持久卷附加到 /mnt/ 并在此 /mnt/ 中安装一些配置映射 我尝试过的： 我…

在 JOLT 中添加条件语句

我有一个 JOLT，可以将温度值转换为摄氏度。我在 NIFI 流中使用它，并获得具有不同值的不同 JSON 输入。当有温度场时，我的 JOLT 工作正常......

将字段从 json 对象移动到有条件的另一个对象

我有以下 JSON 结构： { “1”：{ "前面的 ID": "0", “值”：“A” }, “2”：{ “precedingId”：“...

如何运行 NiFi-toolkit docker 镜像

我尝试启动 nifi-toolkit 的容器，收到错误消息“未指定程序选项”。可用选项包括： encrypt-config s2s flow-analyzer node-manager tls-toolkit file-mana...

Apache Nifi 表达式语言：查找与正则表达式匹配的部分内容

任务是找到表达式中与所选正则表达式匹配的部分，并将该部分放入新字段的值中。 例如，“描述”字段中的表达式： “拉蒂特...

在 nifi 应用程序中运行的 Python 脚本，用于在最后时钟大于 nowminus1 分钟时根据流文件内容路由流文件

{ “最后时钟”：纪元格式， “最后值”：98.5778 } 我想根据最后一个时钟值来路由流文件，如果它大于现在 - 1 分钟，则路由到成功，剩余到失败

无法完全删除Mac中的NiFi状态（本地设置）

我安装了 NiFi 的本地版本，并使用 InvokeHTTP 处理器创建流程。这导致了一个错误，我得到了 { “状态”：404， “消息”：“未找到” } 然后我尝试了...

使用 Apache Nifi 进行具有关系的 ETL 多个表

我想使用 Apache Nifi 将数据从 Oracle 数据库 ETL 到 MS SQL Server 数据库。 目标数据库，有 2 个表（有关系）和一个 1-n 基数（n 值很大，这样...

在nifi上找不到putIceberg

我一直在使用 Apache NiFi 并尝试安装多个版本，特别是 1.19.0、1.23.2 和 1.27.0。但是，我遇到了找不到 PutIceberg 的问题

值无法转换为时间戳（Nifi 中的错误）

我有一个列类型为日期时间的mysql目标表。 我的nifi流程就像convertJsontoSQL -> putsql（到这个目标表中）。 putsql 的操作是删除。 转换后