我从csv文件向kafka写消息。我的生产者说所有数据都以Kafka为主题。
此外,我使用apache nifi作为kafka
尝试使用NiFi路由属性。
我正在尝试获取一个json文件,其中两个json记录包含以下属性(此文件中还有其
Apache NiFi ||如何在Executeprocess处理器中传递powershell命令。
我想在远程计算机上执行powershell脚本,
我有六个文件名为
<ol>
<li> weather_daily.zip </li>
<li> weather_hourly.zip </li>
<li> weather_yearly.zip </li>
<li> weather_d
我使用汉堡菜单创建了一个新的PrometheusReportingTask,然后选择“所有组件”策略,如下所示:
<a hre
我使用UpdateAttribute检查速度较慢的处理器的时间。第一个UpdateAttribute具有<code>DATA_START ${now()}</code>,而第
我必须过滤传入的流文件流(下图中的<code>Input to API*</code>),并根据它们的要求(通过某些属性)通过
我的问题是Nifi无法完成启动。大约40秒钟后,run-nifi.bat发出的CMD窗口消失。因此,GUI无法连接,因此无
<strong> NIFI GetMongo </strong>
使用mongodb的_ ID作为同步mongodb数据的偏移量,但是不能在nifi的getmongo或ge
我想将json数据转换为avro。
我使用了GenerateFlowFile并将虚拟json值[{“ firstname”:“ prathik”,“ age”:21}
我想将json数据转换为镶木地板形式。
我已经使用了GenerateFlowFile并放置了虚拟json值[{“ firstname”:
我想使用HandleHTTP处理器在Nifi中托管API。我想获得一些有关如何做的信息/资源。
我是Nifi的新手。
预先
我想使用HandleHTTP处理器在Nifi中托管API。我想传递一些虚拟json数据。我想将JSON数据转换为avro,然后将其
我在本地计算机(例如端口(8090))上运行Apache NiFi(version1.11.4)。
它在我的机器上运行且运行良好。
我的表有一个二进制GGUID字段。此字段的十六进制值为<code>0x222134A61766432BAC3CA2D8C8058751</code>。
在nifi
在apache nifi中,我无法在工作流程中解压缩zip文件,因为它们受密码保护。我知道密码,对于所有Zips都
目前,我的流文件中大约有15个属性。在这15个值中,我只希望使用其中的几个(所有属性中都带有前缀
我正在尝试获取一个容器化的Nifi实例,以将Active Directory用作流文件源。<br/>
我想定期针对AD运行查询(
我在专用子网中构建了一个Nifi服务器,并使用低于nginx conf的安全Nginx反向代理服务器(已启用SSL的Nginx
我正在尝试将Nifi中的xlsb文件转换为csv。我目前在Nifi中使用ConvertExcelToCSVProcessor,但是它给我错误并且无