apache-nifi 相关问题

Jolt - 在数组列表中插入匹配的字段

下面是我来自合并记录处理器的输入，其中 erp_projectid 是相关属性 JOLTTransformJson 的输入： [ { “priority_id”：8， ”

Jolt 转换 unix 纪元时间戳

是否可以使用 jolt 将 Unix 纪元时间戳转换为特定格式的字符串时间戳？ { “事件”：“CLICK_1”， “时间”：1736356629.9767823 } 到 { &q...

docker 中的 Nifi，在卷中进行配置

我正在尝试保留 nifi 2.0 容器的配置。我的 docker compose 文件类似于： 服务： 尼菲： 图片：apache/nifi：最新 容器名称：nifi 端口： - &q...

在apache nifi中保存大量流文件

我有一个 nifi 流，它将从 Kafka 消费并将消费的数据填充到 ElasticSearch。 有时，ElasticSearch 会因维护而停机数小时。由于 KAFKA 不受影响，...

如何导入NiFi_Flow.json或转换为模板？

我在本地 Docker 容器中的 Nifi Flow 上工作了一整天。完成后，我将流程下载为 JSON 文件并终止了容器。我现在希望将其导入到我的 Nifi 实例中

如何重置nifi中的等待通知计数器

我有一个流程，每次我都必须等待确切的 12 个文件。 所以我写了类似的代码 getHDFS -> 通知 -> 等待 -> 一些处理。 通知有以下配置 释放信号标识符 =

如何调用NIFI REST API来启动/停止生成流文件

我想使用 NiFi REST API 调用启动和停止生成流文件。 例如，我可以使用 NiFi REST API 从 Python 或 Shell 脚本调用 NiFi 生成流文件。

使用输入 JSON 的多种组合来扁平化复杂的嵌套 JSON

我正在尝试编写一个规范来使用摇动变换进行以下变换。我需要将nestedd JSON 转换为平面JSON 我在转换嵌套转换时遇到一些麻烦...

如何使用 Apache-nifi 的 InvokeHttp 处理器发送带有附加文件的 http POST multipart/form-data 请求？

我正在尝试使用 Nifi 的 InvokeHTTP 处理器将多部分/表单数据请求发送到 POST API。此请求需要一个 json 和一个文件。 POSTMAN 中的请求标头和请求正文看起来有些东西

NiFi InvokeHttp：如何在不使用 ExecuteGroovyScript 的情况下使用 multipart/form-data 发送多个文件

通常，当我必须将带有 multipart/form-data 的多个文件发布到 RestAPI 服务器时，我使用 ExecuteGroovyScript，如下所述： http://apache-nifi-users-list.2361937.n4.nabble.com/POST-mult...

是否可以通过InvokeHttp发出x-www-form-urlencoded POST请求

我刚刚开始使用 Nifi，想知道是否可以执行内容类型设置为 x-www-form-urlencoded 的 POST。 我需要将这些键/值传递给我的请求： 授予类型：

HTTP Post 标头未到达 nifi

我对 NiFi 还很陌生。 我正在使用 Python 向 Nifi 发送包含文件和一些标头的 HTTP 帖子： 标题= { "文件名": "文件名", “response_url”...

向 PostHttp 处理器或 Apache Nifi 添加标头

我正在尝试在 Apache NiFi 中的发布请求标头中添加自定义标头，我已经看到在配置选项卡中，有一些属性要作为 HTTP 标头（正则表达式）发送，我不太熟悉。 .

MiNiFi - 如何获取处理器列表和排队流文件的数量？

我想监视正在运行的 MiNiFi 流的状态，特别是获取处理器列表和每个处理器的排队流文件数量。我正在尝试使用 FlowStatus 脚本查询，例如： $ ./米...

Nifi 逃生管道角色 Jolt Transform

有没有办法在NiFi上的JoltTransformJSON处理器中转义管道字符（|）？ 我有一个 Json，其中有许多具有该字符的属性名称，我需要使用 JoltTransform 将其展平，...

在nifi jolt中将字符串拆分为数组

我正在寻找 jolt 规范，以将树字段字符串值拆分为下面提到的格式的 JSON 对象列表。 有人可以帮我处理颠簸规格来转换下面提到的 inp...

NiFi调用HTTP API后，如何在调用HTTP API之前获取原始流文件

我有以下调用 Rest API 的顺序。 生成流文件 ↓ 评估JSONPath ↓ ReplaceText（用于后期数据创建） ↓ 调用HTTP ↓ 评估XPath ↓ 原始流文件（

如何通过 InvokeHttp NiFi 发送多部分/表单数据

我有一个第 3 方 REST，我可以使用 CURL （shell）成功地像这样调用它。该 API 返回 JSON。我尝试通过将内容类型更改为 application/x-www-form-urlenc 来调用相同的 API...

如何在 Jolt 变换中连接两个属性

我有以下 JSON 格式的输入： { “名字”：“斯科特”， “姓氏”：“帕克” } 我需要以下结构的输出： { “数据”：...

Jolt 变换 - 如何连接两个属性

我有以下 JSON 输入 { “名字”：“斯科特”， “姓氏”：“帕克” } 我需要输出遵循结构 { 数据： { “全名：”斯科特·帕...