apache-nifi 相关问题

Apache NiFi是一个易于使用,功能强大且可靠的分布式系统,用于转换和分发数据。

无法解析Nifi中的groovy.yaml.YamlSlurper类

使用 Nifi 1.23.2 我无法解析 ExecuteScript 处理器 (Groovy 3.0.17) 或 ExecuteGroovyScript 处理器 (Groovy 3.0.18) 中的 YamlSlurper 类。具有最小的脚本主体,例如

回答 1 投票 0

Apache Nifi - 从 Avro 提取属性

我正在尝试从 Avro 和 JSON 中提取属性。我可以使用 EvaluateJsonPath 处理器从 JSON 中提取属性。我正在尝试在 Avro 上做同样的事情,但是我...

回答 2 投票 0

如何从Apache Nifi中的json数据中提取这个键值?

我需要从给定的数据中提取这个密钥9876。这将在 nifi 的处理器中可用,我必须将其提取到变量中。 因为它在钥匙侧或右侧我不明白......

回答 2 投票 0

如何在apache nifi中复制其他字段的值

我有一个 JSON : { "_id": "gkpYcLowAADQiQiiX", “团队”: [ { "用户ID": "L2Q6Nd9Z7KhdXgeis", “角色”:“用户”, ...

回答 1 投票 0

Shiftr 需要 Map 类型的规范,得到 ArrayList

我正在使用 nifi-JoltTransformJson 处理器 [1.9.2] 版本,我有一个输入 json,如下所示,其中规范 json 作为属性。 输入 JSON: { “你的订单”: { “订单 ID&

回答 1 投票 0

修改后JSON中对象的顺序

例如,我的 JSON 如下所示: [ { “id”:1, “价格”:400 }, { “id”:2, “价格”:500 }, { “id”:3, &

回答 1 投票 0

Jolt - 在数组列表中插入新字段

我在 Jolt 转换方面遇到问题,我需要从数组列表中提取值/字段,并从我要提取的数组或外部列表中添加一个自定义字段。但让我尝试解释一下...

回答 1 投票 0

如何将 Apache IoTDB 与 Nifi 集成以使用 `PutIoTDBRecord` 和 `QueryIoTDBRecord` 处理器?

我查看了官方指南,知道Apache IoTDB可以使用nifi-iotdb-bundle工具与Apache NiFi集成。我想问一下,如果我想使用PutIoTDBRecord和

回答 1 投票 0

按值分割字符串并用它填充 JSON (NiFi)

我有一个 JSON: [ { “id”:1, “状态”:0 }, { “id”:2, “状态”:0 }, { “id”:3, “状态”:1...

回答 1 投票 0

Apache Nifi:从 REST 加载数据到 Druid

我正在使用 Apache NiFi。 从 REST API 向 Druid 加载数据的正确方法是什么?

回答 3 投票 0

If 条件 + 与 JOLT 串联

我有一个 JSON: [ { “id”:0, “错误代码”:603, "error_desc": "某些广告发生错误:需要网址。", “任务ID”:630 }, { “……

回答 1 投票 0

NiFi中的ValidateXml处理器支持XSD版本1.1吗?

NiFi中的ValidateXml处理器支持XSD版本1.1吗?

回答 1 投票 0

Nifi 等于条件不匹配

为什么第一个条件总是跳过 ${name:equals('xxx'):not():or('zzz'):not():or('aaa'):and(${number:equals(1)})} 是 ${名称:等于('xxx') 被 NiFi 跳过 哪一个条件并不重要...

回答 1 投票 0

有没有一种解决方案可以更新Redis中某个键的Json值之一,而Json是Redis键的值?

我在 Redis 中有“x”键的 Json 值: {“键1”:“值1”,“键2”:“值2”} 在 Apache Nifi 中,我有具有相同 Json 键的流文件内容: {“k...

回答 1 投票 0

ConvertJSONToSQL Json 没有 updateKey 列的值

我是 apache nifi 的新手。我已经编写了从源数据库到目标数据库的同步流程。目前两个数据库都是mysql。 我尝试将 Transfer 字段 Namesvalue 设置为 true 但

回答 1 投票 0

用表达式读取NiFi中的文件

我有一个由电子邮件触发的 NiFi 流程。 问题在于 ListFile 和 GetFile 处理器不是从外部启动的。 我需要的: 我有一些文件: 上下文变量 #{folder_to_read} = /home/...

回答 1 投票 0

安全环境中的 Apache Nifi 和注册表 - 存储桶不可用

桶不可用 这是我们的设置: 设置安全 nifi 设置安全注册表 都在同一台机器上 在注册表中使用 CN=[主机名]、OU=NiFi 创建用户,并具有存储桶的读取权限,并且

回答 1 投票 0

NiFi 中的 Jolt Transform 可将阵列提升一个级别

运行NiFi 1.23.2.a 我需要将 JSON 中的数组向上移动一个级别。 输入: [ “计数”:50, “插入”:{ “在”: [ {“类型”:“值1”,“需要...

回答 1 投票 0

如何在nifi队列中插入值

对于 imgae,第二个队列中只有一个值(数字)。 如何使用 SQL 将数据(队列中的值)插入表中? “插入表值(队列)” 我要插入1321...

回答 1 投票 0

处理来自 GetS/List SFTP 处理器的最新文件

我从 List SFTP 处理器获取多个文件。然而,要求是仅根据文件的上次修改时间处理最新的文件。我尝试通过合并内容专业程序合并文件...

回答 2 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.