我在NiFi中有一个处理器，看起来像这样：
基本上，ExecuteStreamCommand会运行Python脚本来做一些处理，然后流文件将转到RouteOnAttribute来检查之前的Python如果成功，它将转到下一个处理器(我在此图中没有显示)。但如果失败，流文件将转到另一个ExecuteStreamCommand处理器发送警报通知(通过电子邮件、聊天等)。我这里的问题是，如果python脚本中有错误，它将一直保持警报，
浏览 2提问于2019-08-12得票数 0
Nifi中是否有一种运行python脚本的方法，该脚本具有从不同文件夹导入的模块、在pipfile中指定的需求以及要传递的参数？简而言之，如何使用Nifi执行通常在我的虚拟环境中运行的python脚本？
我的最终目标是使用Get获取一个文件并将其发布到API中。我试过执行进程，执行流命令处理器。
浏览 1提问于2020-04-22得票数 0
1回答
我已经找到了一些在Python中实现类似于SICP的流的好例子(，)。但是，我仍然不知道如何处理像SICP3.5.3“integral”中的一个例子。(add-streams (scale-stream integrand dt) int)
这个问题的棘手之处在于返回的流int是根据自身定义的(也就是说，流int用于流int的定义)。我相信Python可以有同样的表现力和简洁。但不确定怎么做。
浏览 2提问于2015-10-02得票数 3
回答已采纳
1回答
我想从python中的dynamodb流中读取数据，到目前为止我发现的替代方案包括
PS:我已经考虑过使用lambda函数来处
浏览 1提问于2016-04-27得票数 23
我想使用Python的来分析很大一部分文本，它的大小可以达到1GB。
是否有可能将文本作为流来解析，这样我就不必将整个文本加载到内存中了吗？我想逐行查看文本，并对其进行详细分析。这有可能吗？
浏览 0提问于2018-10-05得票数 1
回答已采纳
我想从业务角度监控Nifi中的流文件。
因此，我使用python脚本添加了executescript处理器，该脚本创建消息，并在每个处理器之后在elasticsearch中推送相同的消息。我想要这个executescript处理器的父处理器名或id，这样我将在流文件中保持附加，这将允许知道这个流文件通过哪个阶段/处理器，并且我可以在ELK中监视它。
浏览 1提问于2019-03-27得票数 1
回答已采纳
对我来说，ExecuteStreamCommand似乎是一个完美的处理器，原因如下：
调用pytho
浏览 0提问于2018-03-24得票数 12
回答已采纳
我正在使用python + Django来处理传入的web请求，这些请求可以将大量的JSON附加到post数据字段中(例如var1=abc&json_var=lots_of_data&other_var=xxx). )我想用自己的流JSON解析器以流的方式处理json，它使用一个类似文件的句柄作为它的输入参数。基本上，我想做以下几点：
POST请求w/ => Django/python =>创建类似文件的句柄来读取POST =><em
浏览 4提问于2017-06-03得票数 3
回答已采纳
我已经在我的脑海中钻了一句：(至少在PHP中)使用try... catch块来进行流控制是很糟糕的。我学到的是只使用它们来处理意外的错误，而不是确定程序的逻辑流，因为catch块是昂贵的。现在我正在学习python，我在任何地方都看到了很多例外和原则。这是否意味着python在处理异常方面效率更高，所以我不需要为流控制而担心它们，还是这个原则仍然有效？如果不是，PHP是规范中的例外(与其他语言相比)，还是Python？
浏览 12提问于2011-01-17得票数 21
回答已采纳
我想：
如何收集数据并将其作为输入发送到python脚本？我能用流处理器实现这一点吗？我可以在/从WSO2中执行python吗?或者它应该与WSO2分开运行吗？如果是的话，我应该使用WSO2的哪个组件？
浏览 0提问于2019-03-15得票数 0
我正在使用python、tensorflow、opencv和usbcamera从直播流视频中检测人脸和情绪。它通过本地终端工作得很好。我试着通过浏览器运行摄像头。如何通过webrtc向python发送视频流。有没有可能使用python逐帧获取webrtc结果，因为我想在这里做一些处理。
浏览 4提问于2018-09-14得票数 0
1回答
我有一个使用python作为脚本语言的应用程序。当有人修改python脚本时，我想知道它是否有语法错误。我使用python.exe (windows2003，python2.5)来检查脚本，所以我执行如下内容但是尽管script.py有语法错误，errors.txt仍然是0kb，在这种情况下，python检测到的错误会显示在屏幕上(但不会重定向到文件)。
浏览 1提问于2011-04-13得票数 0
回答已采纳
我在这里使用python脚本。我想在nifi中将ExecuteStreamCommand处理器的输出流关系结果添加到原始流文件中。
浏览 14提问于2022-06-14得票数 0
回答已采纳
2回答
我目前正在python 3.6.5上运行一个气流(1.9.0)实例。我有一个手动工作流，我想移到DAG。这个手动工作流现在需要用python 2和3编写的代码。数据流作业，用于处理数据并为机器学习培训设置数据
数据流作业是用python2.7编写的看看气流1.9.0中的"MLEngineTrainingOpe
浏览 0提问于2018-07-05得票数 4
回答已采纳
1回答
我需要使用python处理图像(应用过滤器和其他转换)，然后使用HTTP将其提供给用户。现在，我使用的是BaseHTTPServer和PIL。问题是，PIL不能直接写入文件流，所以我必须写入一个临时文件，然后读取该文件，以便将其发送给服务的用户。
有没有python的图像处理库可以直接将JPEG输出到I/O (类似文件)流？
浏览 2提问于2013-01-13得票数 7
回答已采纳
如何使用Apache将CSV转换为JSON？"model","speed","mileage""benz",4,10"jaguar",7,
浏览 1提问于2018-11-21得票数 1
回答已采纳
我有一个处理器，可以生成JSON格式的时间序列数据。根据收到的数据，我需要在python上使用机器学习算法进行预测。然后将新的预测值写入另一个流文件。问题是:当您运行这样的python脚本时，它必须执行许多大规模的预处理操作:查询数据库、创建复杂的数据结构、初始化预测模型等。如果使用ExecuteStreamCommand，那么对于每个流文件，每次都会运行脚本。这是真的吗？我是否可以在NIFI中创建一个python脚本，该脚本只启动一次并多次接收流
浏览 5提问于2020-06-03得票数 0
2回答
我在python中找不到类似的API。Apache Kafka是否支持python中的流处理？
浏览 0提问于2018-08-19得票数 17
回答已采纳
3回答
每用户流处理
、、、、
我需要处理来自一组流的数据，独立于其他流对每个流应用相同的细化。有没有像storm，spark streaming或samza这样的框架来实现这一点？如果支
浏览 4提问于2015-06-17得票数 1
在django或python中有可见的工作流引擎吗？在前端网页中，用户可以通过可视化的工作流界面，无需编码即可处理工作流。如果有这些工作流程，请推荐给我它的名字。非常感谢!
浏览 2提问于2018-07-05得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
