apache-nifi 相关问题

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

如何在nifi中插入、更新、删除表记录?

我正在学习nifi流程,我尝试实现一个场景,在该场景中我们将同时插入、更新和删除表记录。 我在两个不同的数据库中有两个表。

回答 1 投票 0

计算下一个小时何时开始

如何计算以纪元毫秒为单位的时间,下一小时何时开始?我的意思是,例如现在我的时间是 19.45,下一小时是 - 20.00。我想获取这个时间(纪元中的 20.00)并将其存储为属性。我...

回答 1 投票 0

使用表单数据请求 apachenifi 处理器进行 POST 请求

我正在尝试使用 nifi 处理器从 InvokeHTTP 1.20.0 发布一个请求。但是无论我更改处理器的什么设置都不会引发任何错误,但仍然不会向服务器请求。这是

回答 1 投票 0

Apache Nifi 处理器在返回 HandleHttpResponse 之前更新 JSON 数据

我的 Apache 处理器设置是 HandleHttpRequest->InvokeHTTP->HandleHttpResponse。我正在使用 Postman 的 API,它调用另一个 API 并获取 JSON 数据并返回。 现在在中间

回答 1 投票 0

如何修剪和更新NiFi的属性值?

我想修剪主题前面和/或后面的所有空白。 使用的 NiFi 处理器: 获取文件 提取文本 更新属性--问题就出在这里 属性转JSON 将JSON转换为SQL ...

回答 1 投票 0

使用 Jersey 客户端升级 Spring Boot 3:ClassCastException:尝试强制转换 jar:文件:

我正在将我的java spring boot应用程序升级到spring boot 3。 我将 org.glassfish.jersey.core:jersey-client 从版本 2 升级到 3.1.3,使用 jakarta 而不是 javax 包。 问题是...

回答 1 投票 0

配置一个nifi处理器运行一次

大家早上好。我希望你们都保持安全并呆在家里。所以我的问题是: 我有一个nifi项目 InvokeHttp 正在执行“POST”方法,并且generateflow 处理器协...

回答 1 投票 0

如何在 NiFi 中使用 Jolt 将两个 JSON 数组合并为一个合并数组

我有一个需求,需要将两个 JSON 数组合并为一个。目前 JSON 是这样的: [ { “测试”: [ { “计数”:5, “姓名”:&

回答 2 投票 0

如何使用 Jolt nifi 将两个 json 数组合并为一个合并数组

我有一个需求,需要将2个json数组合并为一个。目前json是这样的: 测试:[{ 数量:5 名称:高速公路 }], 测试:[{ 数量:6 名称:高原 }] 现在我需要合并电子...

回答 1 投票 0

JOLT 转换,每个内部数组都有重复元素

我需要 JOLT 规范来进行以下转换。因此存在长度相同的数组(在本例中为 3),因此我想将其扩展为 3 个记录,并重复非数组值。

回答 1 投票 0

Nifi - 将根 json 元素拆分为不同的流文件

我有一个数据源,正在发送包含各种键值对的 json 格式的消息。每条消息中包含哪些密钥并不一致。但是,我需要将每个人分开......

回答 1 投票 0

如果输入表太大,Ni-FiGenerateTableFetch不会产生输出

我创建了一个 Apache Ni-Fi 数据管道,它从 MySQL 表中获取数据,并在进行一些数据转换后将数据加载到 postgreSQL 表中。第一个处理器是GenerateTableFe...

回答 1 投票 0

如何在 JOLT 中使用“$”字符?

我正在尝试使用 JOLT for Apache nifi 进行一些数据转换,但遇到了一些问题。 示例输入是: { “id”:“1234” } 示例输出为: { “$

回答 1 投票 0

使用 Apache Nifi 的 Python SDK 启动 NIFI 处理器

我有一个Python代码,它试图使用用户名和密码对我的Nifi服务器进行身份验证,以启动其中的处理器。 下面是我的代码: 从烧瓶导入烧瓶 导入nipyapi 进口重新...

回答 1 投票 0

Apache NiFi 与 Informatica

有人对 NiFi 和 Informatica 进行过比较吗? 我没有使用 Informatica 工具的经验,但据我了解,它是一个 ETL 工具,如果您的用例涉及...

回答 2 投票 0

NiFi 与 Sentry.io 集成

我正在尝试从 nifi-app.log 捕获异常。 有些异常我无法捕获,因为它们仅发生在处理器的右上角。 另外,我想发送哨兵

回答 1 投票 0

NiFi 将 mysql 查询结果加载到属性中

我正在使用 ExecuteSQL 处理器执行简单的行计数查询。我需要根据值来路由流量。目前,除了 ExecuteSQL 处理器之外,我还需要使用 ConvertAvroToJSON AND

回答 1 投票 0

Jolt:数组中两个字符串的连接

iam 尝试连接数组中的两个字符串并尝试了 in jolt。我无法出去: 输入是: [ { “政策”:“名称”, "setFrstNm": "约翰...

回答 1 投票 0

apache nifi:“执行节点”无效,因为无法仅为主节点调度具有传入连接的处理器

我在nifi flow中有一个处理器。它基于 FetchFile。 在调度选项卡上,它将执行设置为“主节点”。 当我使用 nifi 1.10.0 运行此模板时,它没有任何问题。但对于 1.22.0,我...

回答 1 投票 0

如何从 Apache NiFi 1.15.3 及更早版本升级到 1.17.0 或 1.18.0?

将 Apache NiFi 从 1.15.3 及更早版本升级到 1.17.0 时,我应该如何处理从 flow.xml.gz 到 flow.json.gz 的转换?我应该选择自动迁移还是手动重命名...

回答 1 投票 0

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