apache-nifi 相关问题

NiFi如何清除所有队列

我目前使用的是NiFi 1.5.0（但与之前的版本相同），我想知道是否有办法同时清除所有队列？ 当处理器数量增加时，可以

从 NiFi 中的文件中提取文本

我有一个简单的用例。我有一个传入文件，每一行都有用户名和用户地址。用户名是从字符1到字符5，用户地址是从字符6到字符15。如何使用Repla...

如果流文件属性值相同，则合并流文件的内容

如果我们发现流文件属性值中有任何匹配项，我想将流文件的内容合并到单个流文件中。 我不知道流文件属性值的确切值，所以我无法使用

如何使用NiFi在消息的元数据部分添加Kafka偏移、分区详细信息

从 Kafka 读取的实际消息： { “身体”： { “元数据”：{ “id”：“bce16e11” }, “活动详情”：{ “事件ID”：“

在 NiFi 1.13.0 中将 CSV 转换为 AVRO

我想将 CSV 数据流转换为 NiFi 1.13.0 中的 AVRO，并将其发送到带有密钥和架构的 Kafka 主题。 所以我有多个问题： 在 AVRO 中转换我的文件（兼容 Kafka To...

替换文本处理器不会改变我需要的部分

我有一个替换文本处理器，我需要更改部分文件内容， 让我举个例子，这些行属于将要处理的文件； 030 111111 22222 333333 ...

是否可以模仿NiFi中的LOOP控制结构？

我有数百个来自不同数据库或 API 的表。其中一些数据源之间存在依赖性，因此我对它们进行了排序并将整个流程设计为线性模式：我让

如何从apache nifi中的输入队列中查找流文件的数量

我想从给定的输入流文件中读取流文件的数量作为参数，假设我的输入队列包含三个流文件，在我的下一个处理器中我想将其作为参数读取

是否可以让NiFi处理器运行但通过未更改的流程文件？

我有一个特殊的用例，我需要使用 ExecuteSQL 调用 sql 过程，但我需要返回进入该处理器的完全相同的流文件，而不是返回过程结果。 是吗

如何在客户Python处理器中指定读取器服务PropertyDefinition？

我创建了一个最小的 python 示例来设置读者服务属性定义： 从 nifiapi.properties 导入 PropertyDescriptor 从 nifiapi.flowfiletransform 导入 FlowFileTransform，

如何使用表达式语言将部分属性文本转换为大写

我正在尝试使用 nifi 表达式语言更新属性。我现在被困住了。 源属性值为： “key1”=“xXx”，“key2”=“yyy”，“key3”=“...

Flowfile 目前在 NiFi 中的 ExtractText 和 PutSQL 处理器之间的 Apache NiFI 中受到惩罚

我需要从文件中读取用户名（全部换行）并插入到数据库（oracle）中。 我在 NiFi 中使用 GetFile->SplitText->ExtractText->PutSql。一切正常...

nifi 1.23.2 string类型值不允许默认为null

nifi 已升级至 1.23.2，我们发现了潜在的不兼容问题： 我们有一些基于此模式序列化的消息： {“名称”：“myKey”，“类型”：“字符串&...

Ni-Fi 导入模板未显示

我在本地系统中安装了 Ni-Fi 2.0 M4 系统。但是在我的本地系统中，我无法从另一个 Ni-Fi 服务器导入模板。附上图片供您参考。有吗

在 NiFi 上使用 JOLT 规范，如何删除仅包含空字符串的数组？

这是我将放入 NiFi 中的 JOLT 转换处理器的输入 JSON。 { “客人”：{ “艾米”：“艾米”， “Theresa”：[“厨师”...

在 K8S 中创建容器时如何将 python 脚本传递到容器？

我有 Apache Nifi 在 Kubernetes 中工作。我已经使用 yaml 文件部署了它。 我有几个想要在 Apache Nifi 上调用的 Python 脚本。 我使用这个 yaml 文件来部署 Apache Nifi： apiVersi...

通过 JOLT 将 json 内的数组拆分为多行

我想通过 JOLT 将 JSON 内的数组拆分为多行。这里数组内的值的数量可以变化。 输入 JSON： [ { "stationname": "站绿"...

如何通过安全连接在整个 nginx 中运行 NiFi

我有 NiFi，通过 Keycloak 进行 OpenId 身份验证。一切都很好。但又出现了一个额外的任务：通过 Nginx 访问 NiFi。我根据 NiFi 文档配置了一切，...

在 NIFI 中将 XML 文件转换为 CSV，不起作用

在将 xml 文件转换为 csv 时，对输出感到震惊。 流文件在convertrecord中的输出 期望输出带有逗号分隔值。 示例输入 xml 是。 在将 xml 文件转换为 csv 时，对输出感到震惊。 convertrecord中流文件的输出 期望输出带有逗号分隔值。 示例输入 xml 是。 <root namespace="namespace_value"> <xmlHeader attr1="9.093" attr2="ralg"> <tag1 attr3="ral2"/> <tag2 attr4="2024-01-02"/> </xmlHeader> <Data> <oneelement/> <tag3 att5="attr5_value"> <tag4 attr6="attr6_value" attr7="attr7_value"/> <tag5 attr8="attr8_value"/> <tag6>tag6_value</tag6> <tag7 attr9="attr9_value"> <tag8>tag8_value</tag8> </tag7> </tag3> </Data> <Data> <oneelement/> <tag3 att5="attr5_value"> <tag4 attr6="attr6_value" attr7="attr7_value"/> <tag5 attr8="attr8_value"/> <tag6>tag6_value</tag6> <tag7 attr9="attr9_value"> <tag8>tag8_value</tag8> </tag7> </tag3> </Data> <tag9> <tag10 attr10="attr10_value"/> </tag9> </root> NiFi 中的 XML 到 CSV 的转换不起作用。 NiFi正在运行的版本是1.27。使用convertRecord处理器的地方。使用 xmlReader 和 csvRecordSetWriter 作为控制服务，其中推断模式。 还尝试使用正确的 avro 格式的 Avro 模式，仍然遇到相同的错误。 非常感谢任何快速帮助。 如果允许手动转换。 您可以尝试在 Microsoft Excel 中打开 xml 文件。 使用“作为 XML 表”打开 XML 文件 示例 xml 文本如下所示： 您可以将 Excel 工作表保存或导入为 csv 文件。

通过JOLT将密钥替换为JSON中的不同代码

我有一个 JSON 输入，如下所示，需要用其名称替换机器密钥，然后需要具有以下输出 JSON 和所需的映射。 距离 - “代码”：“X2-P1”...