如何使用处理器ExecuteStreamCommand或ExecuteScript将CSV原始源从GenerateFlowFile处理器转换为Excel文件 以及如何运行Python虚拟环境( env)来使用Python项目中的依赖项？
浏览 76提问于2021-08-26得票数 0
回答已采纳
我目前在Apache处理器ExecuteStreamCommand和Python脚本的实现方面遇到了问题。 我写了下面的代码将50个不同的csv文件转换成json。import json sep='\t',', lines=True) 该脚本在我的本地目
浏览 29提问于2021-08-17得票数 0
回答已采纳
我一直在使用Nifi将大量深嵌套的xml文件转换为csv。
MergeContent (与fragment.identi
浏览 3提问于2019-07-04得票数 0
我正在尝试设置一个简单的过程来修改我的CSV文件，并使用Apache Nifi将其摄取到elasticsearch DB。我不想在将文件从一个处理器传递到另一个处理器时，在Stdout上流式传输我的CSV文件。
我已经做了两个流程。我的第一个流程是使用python处理器获取我的CSV文件，使用ExecuteStreamCommand对其进行定制，我在其中运行我的GetFile脚本来读取、修改和保存我
浏览 2提问于2019-08-06得票数 0
我正在尝试在Nifi ExecuteStreamCommand处理器中运行python代码。该代码包括非纯python模块，如Pandas和Numpy，因此使用Nifi executeScript不是一个选择。 这个问题与读入流文件和修改流文件内容有关。显然，可以使用STDIN读取传入的流文件，并使用STDOUT将其写出，请参阅此SO问题：Python Script using ExecuteStreamCommand</em
浏览 58提问于2019-02-19得票数 2
1回答
我收到了一个来自.csv处理器的奇怪的FetchFTP文件。site_id,device,placement_name,placement_id,url,clicks,imps,total_record_imps,total_view_imps
有什么工具可以用Apache
浏览 6提问于2021-02-19得票数 0
回答已采纳
在此传输过程中，我必须使用Python脚本屏蔽数据。我在Google Cloud Platform上创建的虚拟机上运行此NiFi，其中我安装了Python-2.7和NiFi-1.9.1。<=\.)[0-9])',value='X')我有以下疑虑：
1)使用getFile处理器，我将队列中的文件传递给
浏览 1提问于2019-04-25得票数 0
我在Windows上安装了所有的东西：2- Apache NififormatConvert 获取.csv文件，将其转换为JSON到SQL，将结果转储到表<code>F 215</code>
浏览 4提问于2022-08-29得票数 0
此外，我喜欢将数据保存在"NiFi管理“之下的想法。
使用更新/新的NiFi
浏览 0提问于2018-03-24得票数 12
回答已采纳
我正在使用Apache在我的excel上执行一个熊猫脚本。table_EVS = pd.read_excel("path", sheet_name="1")
table_EVS.to_csv(output)#Impor
浏览 4提问于2022-09-26得票数 0
回答已采纳
我需要在Nifi中实现ExecuteScript，这样才能完成列的转换，我使用pyspark作为实现的方法。
浏览 0提问于2019-05-27得票数 0
回答已采纳
我是NiFi和Python的新手，我需要您的帮助才能将Flow File属性值传递给脚本。脚本正在将嵌套的json转换为csv。当我在本地运行脚本时，它可以工作。如何将FlowFile名称传递给src_json和tgt_csv？谢谢,import pandas as pdfrom pandas.io.json import json_normali
浏览 0提问于2019-05-10得票数 2
我有一个处理器，可以生成JSON格式的时间序列数据。根据收到的数据，我需要在python上使用机器学习算法进行预测。然后将新的预测值写入另一个流文件。问题是:当您运行这样的python脚本时，它必须执行许多大规模的预处理操作:查询数据库、创建复杂的数据结构、初始化预测模型等。如果使用ExecuteStreamCommand，那么对于每个流文件，每次都会运行脚本。这是真的吗？我是否可以在NIFI中创建一个python脚本，该脚本只启
浏览 5提问于2020-06-03得票数 0
我想使用CURL.Please将.csv文件或mysql表从本地计算机(GetFile)发送到Apache Nifi中的Hive(PutHiveql)，让我知道是否有使用Curl执行此操作的命令。
浏览 0提问于2017-06-28得票数 0
我在Nifi中有一个Collect_data处理器，它将消息流到另一个进程中，使用python脚本解析该进程并创建json文件。问题是，我不知道python脚本中函数的输入是什么。如何将这些消息(16位数字)从Collect_data处理器传递到下一个处理器包含python脚本。有什么好的，基本的例子吗？import sys
from urlparse import urlparse,
浏览 2提问于2018-10-02得票数 3
回答已采纳
我是NiFi的新手。我正在尝试使用ExecuteScript处理器执行Python脚本。当我尝试一个没有导入命令的简单脚本时，它运行良好，并在nifi.StdOut中显示了输出。
浏览 2提问于2019-04-11得票数 3
回答已采纳
我正在使用Apache，将一个FlowFile中的FlowFiles列表转换为多个JSON，每个JSON都有一个JSON。然后，我使用JoltJSONTransform来更新属性(filename)上的键(在json中缺失)。{ "number": "
浏览 1提问于2020-01-17得票数 0
我正在使用csv处理器的.xlsx文件到ExcelToCsv文件的对话。想要转换一堆.xlsx文件，其中有不同格式的数据到csv。将文件转换为csv后，数据将发生如下更改。https://nifi.apache.org/docs/
浏览 5提问于2020-05-02得票数 0
我们将Apache Nifi设置为将文件写入本地驱动器，然后运行处理这些文件的程序，并将响应输出到" response“属性。这是一个JSON字符串，我们随后将其传递给API以更新记录。然而，问题是，尽管我们可以成功地写入、读取和处理文件，但Nifi无法理解响应文本中的非英语字符。当我们发回响应时，这会导致名称被破坏。这只适用于我们从程序中收到的JSON字符串。Nifi正在运行Windows 10环境当我们使用Nif
浏览 2提问于2019-09-11得票数 0
云服务器
ICP备案
即时通信 IM
云直播
对象存储
腾讯云开发者
