apache-nifi 相关问题

无法完全删除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 的操作是删除。 转换后

无法在 Windows 10 上安装 Apache Nifi

我已经安装了Apache nifi-1.8.0。我的电脑上安装了jdk-11.0.2。 我已将 Nifi 文件夹放在路径 C:\Demo 上 ifi-1.8.0 和 jdk 位于路径 C:\Java 上。 我无法启动 Apache nifi。 中：...

Jolt 将键/值动态更改为代码/值

我有以下输入 json 并希望将这些键/值转换为代码/值。并且需要将ts（时间戳）转换为CET时间。这些 x1,x2,.... 键是动态的。它们可以像 y1, y2....

使用 JOLT 表示法将 JSON 转换为 JSON

输入JSON [{ “LSID”：617871， “数据” ： [ { “酒吧绝对”：29.263， “酒吧趋势”：0.049， “ts”：1727693443 }], “传感器_...

如何使用replacetext或任何其他处理器来实现以下场景

{ “身份证”：100， "名称":"jcb", "键盘":[cpu|使用情况,内存|使用情况,磁盘|使用情况] } 我的意思是如何将其转换为完美的 json 键盘":["cpu|用法",&qu...

如何在对象输入的修改覆盖测试操作中使用“=toString”？

我的输入有超过 1000 个键，并且我的输入中几乎没有带有键值对的对象。 我需要将每个对象内部以及外部的所有键值转换为字符串

使用 jolt 从数组中删除 null

我在使用 jolt 从数组中删除空值时遇到一些问题，如下所述： 输入 { “用户ID”：“1”， “年龄”：“20”， “名字”：“

向 Kafka 主题发送自定义消息

任务是将具有具体价值的消息发送到Kafka主题。 例如，我想以纯文本形式发送“someValue”。 我应该使用 PublishKafkaRecord_2_6 中的哪个 Kafka 属性来实现此目的

Apache NIFI 2+ HTTP 错误 400 无效 SNI

HTTP 错误 400 SNI 无效 URI：https://{您的自定义 IP}:8443/nifi 状态：400 消息：SNI 无效 我在尝试为我的开发部署 Apache NIFI 2+ 的新实例时遇到此错误...

显示从对象数组中获取的属性，并在 Jolt Transform 中展平

我有以下震动输入， { "城市代码": "34343", "branch": "城市名称", “更改日期时间”：1677063272522， “标记”：“L”， ...

如何获取Minifi UI Portal

我想从事 minifi 工作，它是 Apache NiFi 项目的轻量级版本。 目前我使用 docker hub 提取了 minifi 镜像 docker pull apache/nifi-minifi:最新 现在我不知道...

Apache Nifi - 流文件卡在队列中

流文件卡在队列中（按属性进行负载平衡），并且不会被下一个下游处理器（带有 CSVReader 和 CSVRecordSetWriter 的 MergeRecord）读取。从 Nifi UI 来看，它似乎...

从 Apache NiFi 连接到 Databricks 的推荐方式是什么

我们一直在使用 Apache NiFi 连接到 Databricks。在升级到 DBR 14.3 和 Nifi 到 1.27 时，我们意识到 SelectHiveQL 和 SelectHive3QL 处理器已被弃用。 什么是

Apache NiFi 处理器中数据来源的目的是什么

对于每个处理器，都有一种配置处理器的方法，并且有一个上下文菜单可以查看数据来源。 对于什么是数据来源有很好的解释吗？

使用 Apache NiFi 高效地从 HTTP API 收集数据并插入 PostgreSQL

我是 Apache NiFi 新手，需要有关处理大量 HTTP API 请求和数据处理的建议。 问题： 我必须从 HTTP API（REST 服务）收集 JSON 数据，从中提取十个字段...

如何在Nifi中减少Epoch时间长度并执行减法运算以获取一分钟前的时间

我有一个用例，我需要生成 Epoch UTC 格式的时间戳，直到秒 1662371646，并执行减法操作以相同的格式生成一分钟前的时间。 下面是我的 Jolt ...

使用 apache nifi 将行追加到 csv 文件

使用 Apache nifi 2.0.0，我没有看到将行追加到现有 csv 文件的选项。 我的设置： 一些生成器，创建一个带有记录数组的 json 字符串 SplitJson 创建单个记录