python - NiFi 的 ScriptedReader 的 Python 示例

Question

任何人都可以为ScriptedReader的Script Body属性提供 Python 示例吗？我用谷歌搜索并搜索了 NiFi 的用户邮件列表，但找不到任何东西。似乎没有关于如何将此控制器服务与 Python 一起使用的文档。

标签： pythonapache-nifi

Answer 1

简短的回答是您不能在 ScriptedReader 中使用 Jython。原因是 Jython 错误阻止您实现具有默认方法的接口，并且从NIFI-4004 (NiFi 1.4.0) 开始，RecordReaderFactory 具有默认方法。有一个相关的案例NIFI-5995添加了相关文档，并从可用于 ScriptedLookupService 组件的脚本引擎列表中删除了 Jython。我已经编写了NIFI-7370来涵盖其他脚本组件的更改，这些组件的底层接口具有默认方法。