Apache NiFi是一个易于使用,功能强大且可靠的分布式系统,用于转换和分发数据。
如何使用 Jolt 规范实现所需的输出 - Apache NiFi
输入: [ { “ImageId”:[“ami-06a13556596424b”,“ami-04d29b6f966df15”], “InstanceId”:[“i-0b456d23d0a5e44”,“i-072b95b1d6a4b11&q...
我面临一个问题,使用摇动转换来转换非常复杂的嵌套 JSON。输入和输出详细信息如下。 我试图创建一个震动规范但没有得到它。有谁可以吗
如果Listfile应包含Nifi中的三个特定文件,如何进行进一步的处理
这是我的文件夹结构: ** abcd_xxx.txt xxx_完成.txt 电话详细信息[0-9]+.txt** 。 我有 ListFile Processor 来选取此文件夹中的所有文件。但如果以上所有情况我应该继续前进...
我想将“id”字段移动到下面文档的“user_roles”字段中的每个元素。 我使用了下面的规范,但它没有按我的预期工作,我不确定我可能在哪里......
如何在 Apache Nifi 中使用 jolt 将字符串更改为在逗号后带有多个数字的浮动
如何在 Apache Nifi 中使用 jolt 将字符串更改为在逗号后带有多个数字的浮动 { “值”:“0.000000123” } 我需要像这样的输出: { “值”:0.0000001...
我已经下载并设置了 Apache NiFi 1.16.3,但是当我尝试在 Windows 中使用 Git Bash 运行设置单用户用户 ID 和密码 (nifi.sh set-single-user-credentials) 的命令时
NiFi QueryRecord 处理器 - 选择可选 JSON 属性
我通过 QueryRecord 处理器得到了几个 JSON 对象。我想从中提取一些属性,包括一些可选的属性。问题是选择可选属性结果...
ssl 证书不起作用 - ERR_BAD_SSL_CLIENT_AUTH_CERT
我正在尝试按照本教程设置安全的 nifi 注册表。 一切设置完毕后,打开网站,我在网页上遇到此错误。 该网站无法提供安全连接。
在Nifi上创建InvokeHTPP时如何排除完整的json文件内容?
我正在制作一个流程文件,它从公共 API 获取数据,然后分割数据以便每条消息都有一条记录,然后将每条消息转换为 CSV,然后通过 g 更新文件名...
NiFi 1.19.1 - 调用HTTP POST 不发送所有标头
我有在集群之间发送的文件,因此我使用 InvokeHTTP 发送到另一个集群上的负载均衡器。我可以发送文件,但并非所有标头都被发送。我指定了
我有下一个数组: [{ “id”:1, "key_word" : "бережливое производство 坎班 сокращение потерь" }, { “id”:2, “关键字”:“” }, { &q...
使用nifi,如何将JSON对象插入Postgres jsonb列?
目前我的nifi流程如下: ListS3 -> RouteOnAttribute -> RouteOnAttribute -> FetchS3Object -> ConvertRecord -> PutDatabaseRecord 我在 s3 存储桶中列出了 CSV 文件并且...
Apache Nifi 2.x - org.eclipse.jetty.http.BadMessageException:400:无效的 SNI
我正在尝试将 NiFi 从 1.24 升级到 2。启动 Nifi 时,服务已启动并且端口 8443 正在侦听。但我在网页上收到错误 400 来自网络: HTTP 错误 400 SNI 无效 URI:...
我正在使用 NiFi QueryMarkLogic 处理器来获取包含 600,000 个文档的集合,并收到一个神秘的错误。我正在使用结构化 cts:collection-query。我的预感是数据量......
处理数组中单个元素或多个元素时的动态震动 如果我们收到一个元素,我的 jolt 规范工作得很好,但如果他们发送一个涉及多个元素的 JSON,那么它
我是使用 Apache Nifi 的新手。我在使用 InvokeHTTP 处理器调用 REST API 时遇到问题。在我查看该处理器的 NiFi 数据来源后。我看到该处理器的类型列是
我已经构建了一个简单的流程组。它生成一个包含一些随机内容的 FlowFile 并将其发送到 Nifi 远程进程组。 该远程进程组配置为发送 FlowFile...
我有来自 PowerTop 工具的 CSV 文件,我需要在将其上传到目标位置之前修改此 CSV。 我想从第 13 行开始操作,该行包含类似......的字符串。
k8s 上的安全 nifi 集群出现入口登录错误:javax.net.ssl.SSLPeerUnverifiedException:主机名未验证
我正在尝试在 k8s 上设置一个 nifi 集群(3 个 nifi pod 和 3 个 zk pod)。 我已经启用: LDAP登录验证 数据持久性 以及用于负载平衡的入口 nifi Web 服务器已启动,正常...
在 Azure Kubernetes 服务上旋转 Nifi 集群时,我在使用 configMap 挂载 nifi.properties 文件时遇到问题。当使用以下配置来安装文件时,我