Apache NiFi是一个易于使用，功能强大且可靠的分布式系统，用于转换和分发数据。
如果该目录不在 helm 图表中，如何通过 helm 修改 pod 内的文件？
我们有一个K8集群正在运行，它是通过helm Chart实现的。有一些目录在 pod 中但不在 helm 图表中，我必须对其进行更改。有什么办法可以改变吗...
nifi 1.21.1 由于政策原因，所有菜单图标均呈灰色。解决方法是手动将用户添加到所有策略中
我安装了nifi 1.21.0并启用了ldap身份验证。 当我登录 nifi web gui 时，在 nifi 画布上，所有图标都变灰了 我可以通过手动添加用户以允许写入来使其全部工作......
如何在NIFI中配置JoinEnrichment来加入两个Flowfile？
如何配置JOINEnrichment来JOIN两个流文件，我选择JOIN策略是SQL，但是对于查询我应该使用流文件方法还是原始和丰富的方法？
我需要使用 jolt 变换将给定的输入 JSON 转换为所需的输出 json 这是我的输入 JSON { “碎片化”：真实， “节点IP”：“192.168.0.20”， “要求...
无法使用PutElasticsearchHttp连接Nifi到Elasticsearch 8.X版本
我正在尝试一个小型管道，该管道从 postgres 获取数据并将其移动到 elasticsearch。通过使用 PutElasticsearchHttp 处理器，它与 elasticsearch 7.4.0 配合良好。 （都茹...
我有两个流苍蝇，我想将这两个流文件读取到groovy脚本中，我在groovy中使用以下行来读取流文件内容，但我如何知道我是哪个流文件。 ..
我们如何将提供的输入转换为所需的输出？ 转换涉及转义字符串并将属性转换为有效的 JSON 格式。但是，任何嵌套属性都...
输入JSON [ { "zone_name": "01 绿色", "zone_type_name": "绿色", “状况”： { “时间戳”...
如何使用 JOLT v0.1.1 转换 JSON 中的日期值
我有这个 JSON 输入： { “实体类型”：“人”， “ID”：24285， “特性”： { “名字”：“齐亚”， “姓氏”：&q...
使用 JOLT v0.1.1 填充 JSON 数组时出现空元素
我正在尝试使用 JOLT v0.1.1 转换从 JSON 输入填充 JSON 数组。但我遇到的问题是，数组在我想要包含的元素之前填充了空元素。 T...
如何在 Apache NiFi 中使用 Jolt 将 JSON 数组转换为嵌套结构？
我正在尝试使用 Apache NiFi 中的 Jolt 将 JSON 数据从输入结构转换为所需的输出结构。这是我的输入 JSON： [ { “位置可用性同步”：{ ...
ListAzureBlobStorage 无法从 ZooKeeper 获取具有 ID 的组件的值
ListAzureBlobStorage 在设置下运行良好： 。 直到它因以下错误而失败，而没有进行任何更改。我已经重新启动nifi并再次重置所有属性。然而，...
使用 JOLT V0.1.1 填充可以包含单个元素的 JSON 数组
我正在研究 NiFi，我想要进行 JOLT V0.1.1 转换，从 JSON 输入生成 JSON 数组。但我遇到的问题是，当 JSON 带有单个电位时
输入JSON { "zone_name" : "01 绿色", "zone_type_name" : "绿色", “状况” ： { "时间戳" : "2024-05-15 10:23:52&qu...
早上好，我想创建一个从某个 URL 到我的 HDFS 的 Nifi 流。我使用我的个人构建和 Dockerfile 在本地创建了 HDFS 集群，它正在工作，但是当我尝试使用
我有这个 JSON 输入： { “输入”：{ "a":"值A", "b":"值B", "c":"值C" }, "fieldsToFilterBy":[&quo...
在Cloudera Data Platform CDP公有云中使用Nifi对Kafka进行读/写
Nifi 和 Kafka 现已在 Cloudera Data Platform、CDP 公共云中可用。 Nifi 擅长与一切对话，而 Kafka 是主流消息总线，我只是想知道： 最小的是什么
Apache NiFi：在 UI 上默认删除用户名和密码登录
我目前正在设置 NiFi，我注意到作为版本 1.14.0 版本的一部分，默认情况下我们启用了安全功能，需要用户名和密码才能访问 UI....
querydatabasetable --> 从源中获取大约 1GB 数据。 Convertavrotojson ---> 将 avro 从 at 数据转换为 json 格式。 splitjson --> 将 json 流文件拆分为单个 json r...
我正在尝试将来自 InputStream 的数据附加为 MimeBodyPart 以作为电子邮件附件发送。我了解如何使用 DataSource 和 DataHandler 对象来完成此操作，但是