apache-nifi 相关问题

如何将几十个字段转换为Nifi属性？

我有几十个字段的json，如何轻松地将其转换为nifi属性？ 我用的是EvaluateJsonPath但是需要一一输入值。 我将在 Phoeni 中使用这些属性...

如何根据列值（csv）在 Apache NiFi 中连接 2 个流文件？

我是 NiFi 新手，目前正在执行一项任务，其中有一个流程文件： “A B C D” “abc”，“jfx”，“daw”，“123&qu...

使用 JOLT Transform 从数组中删除空字符串

我需要为这个转换编写颠簸规范 输入 ： { "key": ["a","b","c","","d","e","f",""] } 输出

Apache Nifi - 由于 /opt/nifi/nifi-current 无法创建而无法启动 Nifi

我将 Nifi 提取到 /opt/nifi/nifi-current 并使用 /bin/nifi.sh start 启动它 日志如下： 启动NiFi服务 Java 主目录：/home/dev/.sdkman/candidates/java/current NiFi主页：/opt...

JOLT 将多个平面数组转换为单个嵌套数组

我似乎无法弄清楚 JOLT 到了令人沮丧的地步。 我可以毫无问题地将所有值放入单个嵌套数组中，但是我无法将值添加到输出的根中。 数据： [...

如何将 JSON 数组值与特定 JSON 结构输出进行比较和提取？

我有一个 JSON 对象，其中包含两个数组：idByLine 和 orderLine。我需要从 idByLine 中提取值，将它们与 orderLine 中的值进行比较，然后生成带有规范的 JSON 输出...

Jolt 将复杂的嵌套 JSON 处理为平面 JSON

当值进入数组时处理嵌套数组的 Jolt 规范 输入 { "昆纳尔": "123456789", “NAME1”：“Milchwerke \“Mittelelbe \” GmbH”...

您可以使用 JOLT 对 JSON 执行 or 条件吗

是否可以在 JOLT 转换上执行多个条件来创建 or 或 and ？ 我找到了一些关于 If Else 的文档，但无法将其应用于我正在尝试的内容。这……

使用 CRON 调度 Nifi 数据流

我在Nifi中设计了一个数据流，使用GetFile和PutDatabaseRecord等2个处理器来读取csv文件并将数据加载到mssql中。当我通过点击“开始”按钮手动触发时，

当有嵌套数组和没有嵌套数组时压平json

处理数组中单个元素或多个元素时的动态震动 如果我们在 PartnerFunction Nested array 中收到一个数组，但如果他们发送 JSON

Jolt 表达式合并二维数组

所以我有地理坐标，我想创建多边形字符串，我可以将其作为几何类型插入到 Postgres 中。我正在使用 Apache Nifi。 输入： [ [ 13、 52 ], [ 13、 55 ], [ ...

如何将nifi flowfile内容作为blob文件插入oracle数据库

我需要将nifi流文件内容作为blob文件插入到我的oracle数据库中，假设下面是我的表列。 id（我将作为一个 nifi 属性获得），名称（这也是我将作为一个属性获得...

如何在 NiFi 中使用 Jolt Transform 构建输出 JSON

我在尝试从 Apache NiFi 中的 joltTransform 处理器构建输出 JSON 时遇到问题。我需要从 idByLine 数组中提取值并将它们与 orderL 中的值匹配...

Nifi 根据一组值验证记录

我想根据一组值验证 nifi 文件字段， 例如：如果 nifi 字段 AGE 在 [7,8,9] 中，CLASS 在 [2,3,4] 中，如果不是无效记录，则认为这是有效记录 知道如何实现...

如何在 Apache NiFi 中使用“验证 CSV”处理器验证可选值时验证/忽略可选值？

我是 Apache Nifi 社区的新手，我一度陷入困境 - 请帮助我解决以下问题： 在验证 CSV 处理器中，我给出下面的 schema(schema_used) 来验证 CSV 输入。但是，

从 Map<Person, list<Property>、List<Feature>> 到 Map<Property, Map<Feature, List<Person>>>

我想知道是否可以对以下用例进行摇动变换 人 { 字符串ID； } 财产 { ID 姓名 区域 地址 } 特征{ 字符串特征ID； } 基本上我们有人哈...

纪元（毫秒）到 UTC 时间戳的转换，在 nifi 中的默认日期（0001-01-01）上添加 2 天

我的 nifi 流程之一是从 JSON 对象获取数据并将其插入到 postgres 表中。 我目前面临从 NiFi 到 Postgr 插入默认时间 -62135596800000 (0001-01-01) 的问题...

从特定字节中提取流文件内容以重命名流文件

我需要从文件中的特定字节中提取内容以重命名流文件。例如 应用程序类型 - (4-6) 字节 发送者 - (8-22) 字节 接收器 - (24-38) 字节 所以流文件名应该看起来像 appt...

Nifi ConsumeKafka处理器，基于空消息的路由

我在nifi中使用ConsumeKafka处理器。我有一个场景来检查收到的 kafka 消息是否为空消息。卡夫卡墓碑场景基本上。并在此基础上进行路由。怎么会这样

Jolt:: 文件数量计数并列出基于源的文件

文件数量计数并列出基于源的文件。 输入： [ { "文件名": "FF/raw/first/raw_A/filenameA_20240212002113.DAT" }, { “文件名”：“...