问题标签 [apache-minifi]

我正在尝试使用 NiFi api 以编程方式创建 NiFi 流。我正在内部流程中创建一个远程进程组。

RPG 请求负载需要远程进程组的目标 uri。有没有办法通过 api 以编程方式获取该 uri？

提前致谢

我正在使用 NiFi api 以编程方式创建 NiFi 流。

我在根进程组内创建了一个进程组（我称之为PG ）。在 PG 内部，我想要一个指向根的远程进程组。

远程进程组请求有效负载需要它指向的进程组的目标 uri （在这种情况下是根的 uri）。

有没有办法通过 api 以编程方式获取该 uri？

换句话说，我可以以某种方式以编程方式获取根的uri吗？

提前致谢

在创建 NiFi 流程时，我意识到组件的版本发生了变化。

我知道每次组件更新时版本都会更改 - 但是什么被视为组件的更新？

例如，导致连接版本更新的原因是什么？

我正在尝试找到一些模式，但运气不佳。

提前致谢！

我正在使用 MiNiFi 版本0.5.0运行 MiNiFi 流，并将数据传递到带有 NiFi 版本1.12.1的 NiFi 流

由于版本差距，NiFi 生成的 xml 包含处理器 ListFile 的一些额外属性，MiNiFi 验证器稍后会拒绝这些属性。

有没有办法跳过验证，所以我不必编辑 config.yml 文件来删除这些属性？

提前致谢。

我正在运行 apache MiNiFi c++，流程从GetFile处理器开始。

输入目录包含一些大文件，当我运行 MiNiFi 时，~1.5 GB 以上的文件失败并且没有排队。

日志文件指出：

[org::apache::nifi::minifi::processors::GetFile] [警告] 无法统计large_file_path_here

其他较小的文件按预期排队。

有谁知道可能出了什么问题？为什么处理器不能管理较大的文件？

提前致谢。

我正在尝试在 Apache Nifi 中创建一个流程 - 情况就像这样 1- 使用来自 kafka 的消息（DONE） 2- 转换为有效的请求正文（DONE） 3- 保留转换后的消息 4- 生成一个 oauth2 令牌（它是一个 post api ) 5- 使用转换后的 json 作为请求正文调用一个 post api 并在 header 中发送令牌

我尝试了几种方法，例如将转换后的 json 放入缓存并在生成令牌后获取它，但问题是我无法将令牌传递给 fetchdistributedcache 处理器。我尝试将 json 文件放在我的服务器上，但 getfile 不接受任何输入，因此在获取 token 后无法触发它。

我必须将数据插入到来自前一个处理器的 3 个表中，并且必须在单个事务中处理。有人可以通过 NiFi 提出一个好的方法吗？

我Nifi 1.7.0用来创建流，然后将其转换为Minifi 0.5.0. 当我运行应用程序时，最初它运行良好，但过了一会儿我收到了以下警告消息：

我已经尝试更改nifi.properties文件中的一些参数（更改nifi.provenance.repository.implementationtoorg.apache.nifi.provenance.WriteAheadProvenanceRepository并增加 nifi.provenance.repository.index.threads），但问题仍然存在。

有没有人遇到过同样的问题？

我Nifi 1.7.0用来创建流，然后将其转换为Minifi 0.5.0. 当我运行应用程序时，最初它运行良好，但在一些请求之后我收到 504 错误（SERVICE_UNAVAILABLE），此错误消息位于minifi-app.log：

我对处理器和使用相同的StandardHttpContextMap控制器服务，并且我还增加了参数。HandleHttpRequestHandleHttpResponseRequest Expiration

似乎只有当我增加线程数时才会出现此问题。只有一个线程，它运行没有任何错误。

有没有人遇到过同样的问题？

目前 Nifi 在 3 个数据节点 1、2、3 上运行。我们在这 3 个数据节点上运行 syslog-ng。我们将系统日志临时接收到这 3 个节点中，Nifi 使用 Getfile Processor 获取日志并将这些文件放入 HDFS。现在 3 个节点被 15 个节点替换，syslog-ng 将日志发送到这 15 个节点，我希望 NiFi 从这 15 个节点获取日志文件。你能告诉我如何获取这些文件吗？我可以在这 15 个节点上部署 Minifi 并与 NiFi 集成吗？