apache-nifi 相关问题

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

将带有数组对象的 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

Apachi nifi 问题仅读取选定的列并将其保存到文件

假设我的文件如下 员工姓名、员工编号、工资 AAA,123,5000 BBB,456,6000 中国CCC,789,7000 现在我的下一个处理器应该只包含 empnumber 详细信息,并且在我的 PutFile 处理器中我必须保存...

回答 1 投票 0

Nifi 多部分形式

我正在尝试向 api 发送一个非常简单的多部分表单。我在 apache Nifi 中看不到任何执行此操作的方法,因为它似乎只有一个表单数据输入。好像有很多现有的

回答 3 投票 0

如何使用摇动规范循环数组

我有以下输入 JSON : { “c2”:[ “142.11.242.31:443”, “192.119.110.73:443” ] } 期望的输出: { “国际奥委会”:[ { “国际奥委会&q...

回答 1 投票 0

条件震动变换

我想编写一个颠簸变换,如果类型是Polygon,则将坐标值放入单个数组“坐标”中,并放入属性“x”,“y”,“z&q...

回答 1 投票 0

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