使用 Nifi,我想:
这可能吗?如果是,怎么办?
换句话说:
最佳答案
NiFi的ExecuteScript
支持Jython,它不允许Python原生库(pandas是原生库),所以你不能直接在NiFi中执行这个 Action 。我建议您编写一个完整的 Python shell 脚本,它执行以下操作并使用 ExecuteStreamCommand
处理器从 NiFi 调用它:
Python 封装脚本:
STDIN
的输入(这将是流文件内容)
ESC
处理器的“命令参数”属性将流文件属性作为参数放在命令行上STDIN
输入转换为 pandas 数据帧STDOUT
这将允许将传入的流文件内容发送到此包装器脚本,使用包含的脚本进行所有内部修改,然后将输出从 STDOUT
转换回流文件内容。
https://stackoverflow.com/questions/61785013/
相关文章:
amazon-web-services - 如何替换 AWS Auto Scaling 组中的特定实
wordpress - Post Object Timber/Twig WordPress 问题
java - Intellij Idea : sbt refresh FetchError$Down
django - 将 Django 连接到 Microsoft SQL 数据库
javascript - 在 includes() 中使用 "OR"运算符来试验字符串中是否存在任何
javascript - 如何使用 nestfastify 编写来自 nestjs 异常过滤器的响应