apache-nifi专题提供apache-nifi的最新资讯内容,帮你更好的了解apache-nifi。
我尝试了几种配置,以按照使用nifi的时间表在Windows中运行批处理脚本(cmd)。我认为此配置应使用Execut
我在GenerateTableFetch处理器中使用“组件状态”来确保不会两次从数据库查询相同的数据。由于迁移,必
我有使用NiFi(Invokehttp prcoessor)的python flask API调用的python脚本。我有时(并非总是如此)遇到错误 <p
<em>注意:这不是问题,我提供的信息可能会对他人有所帮助。</em> 大家好, 最近,我花了
我有一个要求,要求以这种方式获取一系列记录: <pre><code>[ { col1: &#39;12&#39;, col2: &#39;AB&#39; }, { col1: &
我正在使用NiFi <code>Version: 1.11.4</code> 我想在NiFi中合并<code>flowfiles</code>。 假设我有10个流文
我有一些日期时间标记,我假装将其分组在紧接其之前的四分之一小时内。 例如,我有以下数据:
我们想使用NiFi将流文件属性(文件名,文件大小,时间)插入Postgres表
我正在使用PutSNS处理器,该处理器将JSON(来自API调用)放入SNS中,在某些情况下,JSON大于256KB,并且我
推荐张贴:<a href="https://stackoverflow.com/questions/43245201/publishjms-processor-fails-while-publishing-json-message-to-ibm-webs
我使用执行速度非常慢的处理器。 因为它需要每次访问表。 如果不优化SQL,不更改执行引擎或不更改表
在使用ConvertJsonToSql处理器时,在Nifi中出现以下错误,它在以前工作正常。.它现在已经出了下面的问题
假设我在群集中有3个节点, <ol> <li>节点A </li> <li>节点B </li> <li>节点C </li> </ol> 在<strong> state-managemen
我正在尝试使用<code>ConsumeKafkaRecord</code>作为阅读器的<code>JsonTreeReader</code>处理器从Kafka进行读取。
我正在尝试在NiFi(1.11.4)中构建一个流,该流从AMQ读取Avro消息,使用Merge Records处理器对其进行累积,
我有一个定制的nifi处理器,该处理器使用外部数据进行某些用户控制的配置。我想知道如何在更改数据
我正在遵循<a href="https://hub.docker.com/r/apache/nifi" rel="nofollow noreferrer">https://hub.docker.com/r/apache/nifi</a>的“独
我们有一个由3个节点组成的NiFi集群,其中部署了100个流。我们已在NiFi中配置了一个任务ReportLineageToAtlas
我正在运行一个NiFi流,其中我有InvokeHTTP处理器通过flask API调用python脚本。当我处理许多文件(以100个为
我正在尝试在NiFi中使用PutRethinkDB处理器。 下面是配置的属性。 (这是一个测试设置,因此nifi和ret