apache-nifi 相关问题

纪元（毫秒）到 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" }, { “文件名”：“...

Kafka Broker + Zookeeper + NiFi KafkaConsumer + Java Producer - SASL_PLAINTEXT 和 PLAIN 选项

对于通过 Kafka 模拟生产和消费消息的项目，我正在尝试设置一个本地环境，使用 SpringBoot Java 作为生产者 -> apache kafka 2.13 作为代理 -> NiFi 1.22 (

当对象之间的JSON数据结构不同时，如何使用Jolt获取属性

有谁在这种情况下如何编写 JOLT 变换： 输入： [ { “id”：“65cf06b62fadc0122dc30f29”， “代码”：“H34.23.9-240216-0003”， ”

如何从nifi中的json文件更新属性

如何将json文件中的字段值放入属性nifi中 json文件： { “_id”：“eCT9agQkchqPnyDgd” } 我使用 updateAttribute 不起作用：$._id，{$._id}

如何根据流文件中的数据过滤流文件？

一个输出流文件有23行数据，流文件中的每一行都有一个键和值。队列中有很多相似的流程文件，如果其中任何一个流程文件不具备所有所需的 ro...

docker中的Apache nifi：无法访问nifi UI

我为 apache nifi 1.22.0 创建一个 docker 映像，在 dockerfile 中公开端口： 曝光 8080 8443 10000 8000 然后我启动一个 docker 容器： docker run -it --cpus=4 --user root --memory=10g --publish

无法按预期填充字段 在 jolt 变换中，如 if-else 和 if-else（嵌套）？

JSON 输入： { “代码”：“+91-”， “状态”：“A”， “号码”：“123456778”， “国家”：“我”， “pukcode”：&...

Apache NIFI - PutElasticsearchHttp - 错误 400

我正在开发一个从 Syslog 获取数据并将其发送到 Elasticsearch 的流程。 我的流程在端口 1514 上使用“ListenSyslog”（当设置为 514 时，处理器给出错误“端口

Nifi 创建全新的自定义处理器时出现构建错误

我正在尝试创建一个新的 Nifi 定制处理器。 我正在遵循 4 个不同教程中给出的说明。 我只创建处理器的结构，我什至不尝试修改 代码和...

Jolt 将键和值转换为单独的数组集

我有一个嵌套的 JSON，如下所示。对象中的键和值需要分成 2 组数组，如预期输出中所示。 输入： { “多发性硬化症”： [ { ...

从数组中提取product.code到Apache NiFi中的新数组

晚安！ 我有一个包含这些数组项的 json： { “项目”： [ { “组织”：“900”， “标识符”：68693000000025， “位置我...

如何在 NiFi 1.23 中仅释放 GetFile 处理器队列中的下一个 csv 文件，直到下游最后一个处理器完成

我开发了一个数据摄取流程，使用 NiFi 1.23.2 处理格式相同的 csv 文件。问题是我只想发布

nifi:jolt：不同名称需要转换，每个名称的数组形成

这是我的输入，我们将基于一个文件名路径进行分组，并将这些相应的文件添加到每个组的单个数组中。 [{ “文件名”：“FF/raw/first/raw_A/

在 NIFI 中使用 JOLT 将 JSON 对象分配为字段值

我有一个存储 JSON 对象的属性“TEST”，我尝试了这个 JOLT，但我得到“无法将 json 编组到对象” 测试： [ { “ORDER_DATE”：“20...

用jolt修改json数组对象

我一直在写一个 json 转换的 jolt，现在已经完成一半了。如果数组中存在，则需要修改数组中的 json 对象，如果根本不存在，则需要创建新对象。

使用HandlehttpRequest初始化服务器失败，绑定失败

`2024-02-12 05:43:26,355 INFO [定时器驱动进程线程 4] org.eclipse.jetty.server.Server jetty-12.0.5;建成：2023-12-18T14:06:32.502Z； git: 3aed62e4959bb8c01f5975fe81e078e3ff626126; jvm 21.0....

使用 ScriptTransformRecord 将时间戳值更改为日期

你好，我正在尝试使用 apache nifi 中的 python y ScriptTransformRecord 进程将 json 中的数据从时间戳转换为日期，我该怎么做？ { “印象_历史_帖子_看过”...