该代码包括非纯python模块，如Pandas和Numpy，因此使用Nifi executeScript不是一个选择。 这个问题与读入流文件和修改流文件内容有关。显然，可以使用STDIN读取传入的流文件，并使用STDOUT将其写出，请参阅此SO问题：Python Script using ExecuteStreamCommand 但是我还没能让它工作起来。尝试简单地从STDIN读取CSV并对其进行修改</em
浏览 58提问于2019-02-19得票数 2
我试图在execute命令处理器中执行python代码，并尝试在代码中读取/写入流文件，例如，我必须使用某些库
例如，在库中，但是我在executeStreamCommand
浏览 0提问于2019-04-25得票数 0
可以用基于文件的提供程序引导UserGroups和策略吗？目前，我们使用org.apache.nifi.authorization.FileUserGroupProvider引导Initial User Identity，使用org.apache.nifi.authorization.FileAccessPolicyProvider在设置NiFi实例时引导Initial Admin Identity。因此，我要做的是编写一个基于UserGroupProvider和AccessPolicy
浏览 3提问于2019-02-15得票数 0
回答已采纳
当我在小文件(les大于1GB)上测试流时，它工作得很好。当我在更大的文件(超过1GB)上测试它时，我得到以下错误：
GetFileid=f1a533fd-1959-16d3-9579-64e64fab1ac6无法检索文件，原因是org.apache.nifi.processor.exception.FlowFileAccessException
浏览 1提问于2017-02-13得票数 5
1回答
我正在使用Apache NiFi来摄取来自Azure存储的数据。现在，我想要读取的文件(100+ GB)可以有任何扩展名，我希望读取该文件的头以获得它的实际扩展名。我找到了python-magic包，它使用libmagic读取文件的头部以获取扩展名，但这要求文件在本地出现。获取数据的NiFi管道如下所示
我需要一种在这个NiFi管道中获取文件扩展名的方法。有办法从内容回购中<
浏览 9提问于2022-02-18得票数 0
回答已采纳
1回答
在Nifi中，我们可以通过两种方式设计一个流：
基于内容的修改(UpdateContent) --在这种方法中，我们直接修改流文件的内容。在每个阶段，流文件内容将被持久化在流文件存储库中。(UpdateAttribute) --在这种方法中，我们将流文件的内容作为属性存储在内存中，并直接修改它们。话虽如此，我也做了并发线程和背压级的修改，但仍
浏览 4提问于2020-06-22得票数 1
我正在码头运行NiFi与所有相关目录挂载为卷。我正在尝试修改我的nifi.properties文件中的一些设置，特别是添加一个自定义属性文件。下面是我当前的nifi.properties文件的一个示例：...如果然后将文件更改为以下内容：
nifi<
浏览 0提问于2019-01-21得票数 6
回答已采纳
当我试图从本地机器访问远程服务器上的VM中的NiFi服务时，我遇到了以下问题。请求在请求/nifi/中包含无效的主机标头。检查请求操纵或第三方拦截.
浏览 13提问于2022-07-05得票数 1
就像我在自定义属性文件中添加一些属性一样。现在，我想在不向上向下Apache NiFi的情况下读取这些自定义属性。custom.properties中的内容destination=/home/ist/d
我想读取这些属性，而不使用向上-向下的NiFi来执行get、put
浏览 1提问于2017-11-18得票数 0
我需要读取每一行，或完整的内容从字符串从FlowFile。但我需要完全阅读所有的文件内容或完全全行。而且在FlowFile类中没有读取所有文件的方法。我使用过的google-chrome历史标记(为了更好地搜索这个问题)：n
浏览 5提问于2022-05-19得票数 -1
回答已采纳
1回答
创建包含自定义处理器和一些默认处理器的进程组&将其添加到桶中。用户sys_admin可以添加组到画布和修改它和它的处理器。用户test_user应该只能将它添加到画布中，而不能修改它(或者它的处理器)。用户test_user仅具有对桶的读取权限。但是用户test_user可以添加处理器组，然后进入并修改它。所以用户只能从一个桶中添加一些东西，而从不修改它？
或者我可
浏览 1提问于2019-03-06得票数 0
回答已采纳
使用Nifi，我想：
运行了一个Python脚本，该脚本导出熊猫的dataframe ，例如通过ExecuteStreamCommand将其发送给各种即插即用的Python脚本，这些脚本输入和输出熊猫的数据，但不知道它们是通过Nifi运行的，而且我无法修改它们以使用STDIN/STDOUT代替大熊猫。
浏览 1提问于2020-05-13得票数 2
我是NiFi和Python的新手，我需要您的帮助才能将Flow File属性值传递给脚本。脚本正在将嵌套的json转换为csv。当我在本地运行脚本时，它可以工作。如何将FlowFile名称传递给src_json和tgt_csv？
浏览 0提问于2019-05-10得票数 2
1回答
我对NiFi InvokeHTTP处理器有一个问题，它要求我对它进行修改。我不是想要更换它，而是要制造一个叉子，我可以用它和原版一起使用。我找到的最简单的方法是克隆代码、签出1.10标记并在nifi/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors目录中运行nifi/nifi-nar-bundles/n
浏览 2提问于2020-05-21得票数 1
回答已采纳
1回答
我希望通过HTTP配置NIFI访问。我已经在nifi.properties中设置了必要的值(或者我认为是这样的)。属性集：nifi.web.http.port=8080nifi.web.https.host=一旦我保存了这个文件
浏览 3提问于2022-01-11得票数 0
2回答
我想将Nifi流文件发送到Spark，并在Spark中进行一些转换，然后再次将结果发送回Nifi，以便我能够在Nifi中进一步操作。我不想写流文件写到数据库或HDFS，然后触发火花作业。我想直接发送流文件到星火和接收结果直接从火花到尼菲。我试过在Nifi中使用ExecuteSparkInteractive处理器，但我被卡住了。任何例子都会有帮助。
浏览 1提问于2018-10-31得票数 8
回答已采纳
我正在扩展一个标准处理器来创建一个自定义的nifi处理器。这个项目构建得很好。但是，当我在将新生成的nar添加到lib/目录后重新启动nifi时，nifi无法启动NoclassDefFoundError： at org.apache.nifi.web.server.JettyServer.start(JettyServer.java:699)
at org.apache.nifi</e
浏览 19提问于2017-08-15得票数 0
回答已采纳
当从文件中读取数据并加载到表中时，我在put数据库记录处理器中收到一个错误，请求无效的转换。 我观察到其中一个表字段数据类型被创建为char。当我将其修改为varchar数据类型时，我可以使用PutDatabaseRecord处理器加载数据。 我使用的Nifi版本是1.13.2。请告诉我如何通过nifi加载字符数据类型值，而不更改表格。
浏览 20提问于2021-10-30得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
