apache-nifi 相关问题

通过JOLT将密钥替换为JSON中的不同代码

我有一个 JSON 输入，如下所示，需要用其名称替换机器密钥，然后需要具有以下输出 JSON 和所需的映射。 距离 - “代码”：“X2-P1”...

通过 JOLT 将 Id 值替换为 JSON 中的名称

我有一个 json 输入，如下所示，需要用它的名称替换机器密钥，然后需要具有以下输出 json 和所需的映射。有人可以帮忙解决这个问题吗？ ** 距离 - “...

如何使用 Jolt Transform 从数组中获取元素并使用 NiFi 中的值创建新属性

我有一个 JSON： {“文件”：“23,21,24,25”} 我需要它看起来像这样： [ { “文件”：{ "第一":"23", “第二”：“21”， “第三&qu...

处理后如何删除或截断流文件内容？

我正在使用 NiFi 处理 ETL 任务。我观察到流文件从头到尾都是流动的。事实上，经过一些处理器，我已经处理了数据。所以我想删除或截断 c...

Jolt 将单个 json 对象转换为每个属性的对象数组

我有一个简单的输入json对象，我想将其转换为一个json对象数组，对象的数量等于属性的数量，并且每个对象继承一个特定的

Nifi ConsumeAMQP 抛出 NullPointerException

我们使用默认的ConsumeAMQP和Nifi版本1.18.0。 RabbitMQ 连接成功，当数据来自 RabbitMQ 时，ConsumeAMQP 处理器抛出 NullPointerException。 一旦出现异常，...

Apache NiFi 9.0.0-m4 - 尝试从 JSON 内容设置流属性

我正在尝试从该内容中获取monitoringType，并将其设置在流属性中，以便稍后在路由到特定弹性索引时使用 [{ ... “平均等待日志”：0。

APACHE nifi 9.0.0-m4 - 尝试从 json 内容设置流属性

我正在尝试从该内容中获取monitoringType，并将其设置在流属性中，以便稍后在路由到特定弹性索引时使用 [{ ... “平均等待日志”：0。

如何从 jolt 中的对象数组中删除 null

我有下面的输入 json，我的目标是编写一个 jolt 映射器，它只会从输入 json 中删除 null 并按原样打印所有其他值。 输入： { “账户”：{ “客户...

如何使用 NiFi JsonPath 获取位置不断变化的特定数组元素的值

如何使用 NiFi JsonPath 获取位置不断变化的特定数组元素的值 输入 JSON： { “电话”：[ { “类型”：“H”， “国家...

如何使用 Apache NiFi 的 PutElasticsearchHttp 处理器从 Elasticsearch 中删除数据？

我使用 Apache NiFi 中的 putelasticsearchhttp 处理器通过提供 Elasticsearch URL 将数据插入 Elasticsearch。现在，我需要使用相同的方法删除和更新 Elasticsearch 中的数据

Apache Nifi - 数据来源选项

有谁知道是否可以禁用内容存储，但将基本元数据（属性）保留在来源内。 我不需要存储流经的文件的内容...

如何将NiFi流文件中的整个json记录（作为单个json字符串）插入到数据库的json列中

我正在使用NiFi从数据库A以json记录格式加载数据，并希望将json记录插入到数据库B中表的json列中。 A => ExecuteSQLRecord => [jsonRow,...] => [?]...

如何在Nifi中的处理器PutDatabaseRecord中设置DBCP ConnectionPool以将数据放入docker Postgres中

首先我要说的是，我是NiFi和数据库的新手，所以我要问的问题是在各种搜索之后没有结果的： 所以，我有一个 Kubernetes 平台......

通过 NiFi 将 JSON 插入 Postgres

我正在尝试使用 AVROSchemaRegistry 和处理器“PutDatabaseRecord”将 JSON 记录插入列类型为 jsonb 的 Postgres 表中。 Apache NiFi版本：nifi-2.0.0-M2-RC4 Postgres

Jolt 变换以删除数组中的重复值

我需要从下面的JSon中删除重复项，如果封闭数组中有重复项，则只应保留一个值。 在下面的例子中，闭数组包含两次 PP21，我想要

apache nifi 2.0.0-M4 - 尝试将 json 值重新定位为 json 的主体

0.4 - 我试图使 /message 的值成为 json 的整体。我尝试过 updateattribute、updaterecord、groovyscript。我在任何地方都找不到这方面的好例子。 我的剪断j...

apache nifi 0 尝试将 json 值重新定位为 json 的主体

0.4 - 我试图使 /message 的值成为 json 的整体。我尝试过 updateattribute、updaterecord、groovyscript。我在任何地方都找不到这方面的好例子。 我的剪断j...

Nifi 无法从密钥库加载证书

我正在学习 NiFi 并尝试在我的组织中使用自签名证书启动 NiFi。我的证书包括 ca.pem、ca.key、nifi.pem、nifi.key。我创建了密钥库、信任库和 co...

使用通配符过滤 JSON 键

我是第一次使用NiFi。 我已经掌握了基础知识，但我认为我犯了一个常见的错误，即以编程方式思考而不是明智地思考。 我得到以下 JSON： { “ABC#01...