NiFi ExecuteScript处理器unidecode模块导入问题及适配咨询

Python 3环境下的可行解决步骤 #

• 先确认NiFi的ExecuteScript绑定的Python版本：NiFi默认会调用系统默认Python，需要修改配置让它指向Python 3.x的可执行文件。可以在NiFi的nifi.properties里调整nifi.script.engine.python.command参数为Python3的路径，比如/usr/bin/python3。
• 给对应Python3环境安装unidecode：用Python3的pip执行pip3 install unidecode，如果NiFi用的是虚拟环境，要先激活虚拟环境再安装。
• 若安装后仍找不到模块，手动添加路径：在脚本开头加入以下代码，把Python3的site-packages目录路径补进去：

  import sys
  sys.path.append("/usr/lib/python3/dist-packages") # 替换成你的实际路径
  import unidecode
  

替代处理器方案 #

如果不想折腾Python环境，可换用以下处理器：

• ExecuteGroovyScript：Groovy自带的工具类或第三方库能实现类似unidecode的功能，比如用org.apache.commons.lang3.StringUtils处理字符转换，或者引入专门的Unicode处理库。
• InvokeScriptedProcessor：支持更灵活的脚本环境配置，能指定自定义的Python环境和依赖路径。

关键排查点 #

• 检查NiFi运行用户的权限：确保NiFi进程的用户能读取Python3的site-packages目录，权限不足会导致模块加载失败。
• 直接验证Python3环境：用NiFi运行用户执行命令python3 -c "import unidecode; print('模块加载成功')"，确认模块在该用户环境下能正常导入。

内容的提问来源于stack exchange，提问作者Aman Gupta