Apache NiFi是一个易于使用,功能强大且可靠的分布式系统,用于转换和分发数据。
使用 JOLTTRANSFORMJSON APACHE NIFI 将属性添加到我的 JSON 文件
我正在尝试使用apache nifi来练习转换数据,我一直在尝试使用GetFile来获取我的4个JSON文件,我的目标是转换这4合1,但对我来说很重要的是要记住...
我有两个具有相同文件名的流程文件(比如说sample.txt)。现在我需要将这两个流文件合并为一个流文件,但是我需要第一个流的数据,然后我必须应用...
Nifi 流已停止工作。今天,在启动流程时,所有处理器图标都变成绿色,但没有输入或输出,因为GenerateFlowFile 显示活动线程和终止线程。这...
无法使用 localhost:8080/nifi 连接到 Nifi
抱歉,关于这个问题有一些问题,但答案对我没有帮助。我有: 启用 ufw 允许从任何地方连接到 8080 的规则 启用 SSH nifi的状态:正在运行、正在监听...
将带有数组对象的 JSON 转换为单独的记录 - JOLT 规范
我正在研究 Apache Nifi 中的 Jolt 变换功能。我对此很陌生,需要帮助。 输入 JSON 可以有多个对象,其中包含需要展平的多个数值数组。 JSON
我需要在我的nifi处理器中获取环境变量。我找到的唯一解决方案是使用 EnvironmentVariableParameterProvider 创建参数上下文。这里的问题是行动应该通过...
如何在 Azure Nifi 中使用 JoltTransformJSON 摆脱 $ 属性
我的 Mongodb 数据库示例架构看起来像这样 { “_ID” : { “$oid”:“5bd761deae323e45a93cddae” } } 从这里开始,我想简化这个 JSON
我正在尝试使用 QueryDatabaseTable 或 ExecuteSQL 在 nifi 中摄取一个非常大的表。它似乎不起作用。相同的查询适用于较小的表。 想法? 谢谢 出现数字溢出
Apache NiFi:PutElasticSearchHttp 无法正常工作,出现空白错误
我目前在同一台计算机上运行 Elasticsearch 版本 6.2.2 和 Apache Nifi 版本 1.5.0。我正在尝试遵循位于以下位置的 Nifi 示例:https://community.hortonworks.com/articles/52856/
我如何在apache nifi中调用我的java程序或jar
我在java中有一个主类,我想从nifi调用该类并使用我的nifi中的逻辑,任何人都可以帮助我 公共类测试演示{ 公共静态无效主(字符串[] args){ ...
我如何从apache nifi中的选项卡分隔的csv流文件中读取第一列和第二列
我在 apache nifi 的流文件中有一个属性,其中值之间用制表符作为分隔符,现在在我的 updateAttribute 处理器中我想读取第一列和第二列值,下面是示例
我想对JSON对象键值的数据进行排序,并且排列应该是升序格式。我可以看到第二个挑战,问题和答案的数量不是固定的......
使用SplitJson后如何在Apache Nifi中合并Flowfiles
我有一个由n个元素组成的数组,每个元素都需要单独处理。处理后,它们需要合并回单个数组。 我使用 SplitJson 来分割这个数组...
当我在 minishift 上运行测试开发时,Apache NiFi 无法构建
当我尝试根据 minishift 上的 DockerFile 代码构建以下链接时,它无法成功运行。有什么办法解决吗? DockerFile 的链接; https://github.com/rromannissen/nifi-openshift/blob/
我想根据某些条件连接多个数据源,我不想创建多个DBCPConnectionPool服务来连接每个数据库,我只想检查我的属性值是否为o...
我想使用作为环境变量传递的参数中定义的 cron 表达式来调度处理器。然而,无论我如何定义这些环境变量,它们最终都会
我已经在 Kubernetes 集群上的 nifi 命名空间下设置了 nifi。 我的服务已启动并正在运行,现在我需要连接到我正在使用 DBCPConnectionPool 的数据库之一。 我得到了
我知道我可以使用表达式语言引用环境变量,例如${MY_ENV}。但是敏感字段不支持表达式语言。还有其他/更好的方法吗?
晚上好.. 我有一个带有以下值的 json: [ { “oid_notas”:12750, “unidade”:“BRYE”, "nota_fiscal": "182477", ”
我正在使用apache nifi,我有一个来自 splitText 处理器的文本文件流,其中包含以下内容,2 行:第一行是 id,第二行是单词。为了考试...