apache-nifi 相关问题

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

使用 JOLTTRANSFORMJSON APACHE NIFI 将属性添加到我的 JSON 文件

我正在尝试使用apache nifi来练习转换数据,我一直在尝试使用GetFile来获取我的4个JSON文件,我的目标是转换这4合1,但对我来说很重要的是要记住...

回答 1 投票 0

如何在 apache nifi 中合并两个流文件

我有两个具有相同文件名的流程文件(比如说sample.txt)。现在我需要将这两个流文件合并为一个流文件,但是我需要第一个流的数据,然后我必须应用...

回答 1 投票 0

Nifi 流不运行并显示活动线程消息

Nifi 流已停止工作。今天,在启动流程时,所有处理器图标都变成绿色,但没有输入或输出,因为GenerateFlowFile 显示活动线程和终止线程。这...

回答 2 投票 0

无法使用 localhost:8080/nifi 连接到 Nifi

抱歉,关于这个问题有一些问题,但答案对我没有帮助。我有: 启用 ufw 允许从任何地方连接到 8080 的规则 启用 SSH nifi的状态:正在运行、正在监听...

回答 2 投票 0

将带有数组对象的 JSON 转换为单独的记录 - JOLT 规范

我正在研究 Apache Nifi 中的 Jolt 变换功能。我对此很陌生,需要帮助。 输入 JSON 可以有多个对象,其中包含需要展平的多个数值数组。 JSON

回答 2 投票 0

在自定义处理器中获取nifi中的环境变量

我需要在我的nifi处理器中获取环境变量。我找到的唯一解决方案是使用 EnvironmentVariableParameterProvider 创建参数上下文。这里的问题是行动应该通过...

回答 1 投票 0

如何在 Azure Nifi 中使用 JoltTransformJSON 摆脱 $ 属性

我的 Mongodb 数据库示例架构看起来像这样 { “_ID” : { “$oid”:“5bd761deae323e45a93cddae” } } 从这里开始,我想简化这个 JSON

回答 1 投票 0

NIfi:如何摄取大桌子

我正在尝试使用 QueryDatabaseTable 或 ExecuteSQL 在 nifi 中摄取一个非常大的表。它似乎不起作用。相同的查询适用于较小的表。 想法? 谢谢 出现数字溢出

回答 2 投票 0

Apache NiFi:PutElasticSearchHttp 无法正常工作,出现空白错误

我目前在同一台计算机上运行 Elasticsearch 版本 6.2.2 和 Apache Nifi 版本 1.5.0。我正在尝试遵循位于以下位置的 Nifi 示例:https://community.hortonworks.com/articles/52856/

回答 4 投票 0

我如何在apache nifi中调用我的java程序或jar

我在java中有一个主类,我想从nifi调用该类并使用我的nifi中的逻辑,任何人都可以帮助我 公共类测试演示{ 公共静态无效主(字符串[] args){ ...

回答 1 投票 0

我如何从apache nifi中的选项卡分隔的csv流文件中读取第一列和第二列

我在 apache nifi 的流文件中有一个属性,其中值之间用制表符作为分隔符,现在在我的 updateAttribute 处理器中我想读取第一列和第二列值,下面是示例

回答 1 投票 0

JOLT-如何根据 json 键值对对数据进行排序

我想对JSON对象键值的数据进行排序,并且排列应该是升序格式。我可以看到第二个挑战,问题和答案的数量不是固定的......

回答 1 投票 0

使用SplitJson后如何在Apache Nifi中合并Flowfiles

我有一个由n个元素组成的数组,每个元素都需要单独处理。处理后,它们需要合并回单个数组。 我使用 SplitJson 来分割这个数组...

回答 1 投票 0

当我在 minishift 上运行测试开发时,Apache NiFi 无法构建

当我尝试根据 minishift 上的 DockerFile 代码构建以下链接时,它无法成功运行。有什么办法解决吗? DockerFile 的链接; https://github.com/rromannissen/nifi-openshift/blob/

回答 2 投票 0

apache nifi中如何动态连接多个数据库

我想根据某些条件连接多个数据源,我不想创建多个DBCPConnectionPool服务来连接每个数据库,我只想检查我的属性值是否为o...

回答 1 投票 0

如何在 Nifi 处理器中使用 cron 表达式的参数

我想使用作为环境变量传递的参数中定义的 cron 表达式来调度处理器。然而,无论我如何定义这些环境变量,它们最终都会

回答 1 投票 0

在NiFi中连接mysql数据库

我已经在 Kubernetes 集群上的 nifi 命名空间下设置了 nifi。 我的服务已启动并正在运行,现在我需要连接到我正在使用 DBCPConnectionPool 的数据库之一。 我得到了

回答 1 投票 0

如何将环境变量传递到参数上下文中的敏感参数中

我知道我可以使用表达式语言引用环境变量,例如${MY_ENV}。但是敏感字段不支持表达式语言。还有其他/更好的方法吗?

回答 1 投票 0

NIFI - 我需要数组的信息,但只需要第一个信息

晚上好.. 我有一个带有以下值的 json: [ { “oid_notas”:12750, “unidade”:“BRYE”, "nota_fiscal": "182477", ”

回答 1 投票 0

如何将文本文件流转换为json文件流

我正在使用apache nifi,我有一个来自 splitText 处理器的文本文件流,其中包含以下内容,2 行:第一行是 id,第二行是单词。为了考试...

回答 1 投票 0

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