Ubuntu环境下Flask API调用rpy2运行R代码报错如何解决

新部署Ubuntu 22.04 LTS环境，需要通过Flask API接口调用R代码执行逻辑。经测试，相同R调用逻辑在终端直接运行、执行独立简单Python脚本时均可正常运行。

正常运行的独立测试脚本 #

import rpy2.robjects as robjects

if __name__ == '__main__':

    print("Mahdi: test")
    robjects.r('''
                library(zoo)
                print("Mahdi")
            ''')

触发报错的Flask服务代码 #

import os

from flask import Flask
from dotenv import load_dotenv

from flask_restful import Api

import rpy2.robjects as robjects

app = Flask(__name__)

load_dotenv()

app.config[
    'SQLALCHEMY_DATABASE_URI'] = f"postgresql://{os.getenv('DB_USER')}:{os.getenv('DB_PASSWORD')}@{os.getenv('DB_HOST')}/{os.getenv('DB_NAME')}"
app.config["SQLALCHEMY_TRACK_MODIFICATIONS"] = False
# 允许接口抛出包本身的异常
app.config["PROPAGATE_EXCEPTIONS"] = True

api = Api(app)

@app.route('/test')
def test():
    print("Mahdi: test")
    robjects.r('''
                library(zoo)
                print("Mahdi")
            ''')
    return {"body": "Nothing"}, 200

if __name__ == '__main__':
    app.run(debug=False, host='0.0.0.0', port=2233)

报错信息 #

NotImplementedError: Conversion 'rpy2py' not defined for objects of type '<class 'rpy2.rinterface.SexpClosure'>'

运行环境版本 #

• conda 4.13.0
• pip 22.0.4
• Python 3.9.12
• R 4.1.2
• Ubuntu 22.04 LTS

报错核心是rpy2自动类型转换机制与Flask默认多线程请求模式的冲突：

• 单脚本运行时全程在主线程执行，rpy2初始化、R环境加载、转换规则注册都在同一线程完成，不存在跨线程调用R对象的问题，因此运行正常。
• Flask默认启动的开发服务器开启多线程模式，每个请求会分配独立工作线程处理。rpy2绑定的R实例本身不支持线程安全，加载zoo这类R包时生成的函数闭包（即报错中提到的SexpClosure对象），在跨线程触发R对象到Python对象的自动转换时，找不到对应转换规则，直接抛出未实现错误。

补充说明：哪怕代码没有显式返回R对象，library(zoo)执行时本身会返回包内导出的函数列表，这些SexpClosure对象会被rpy2自动尝试转换为Python对象，刚好触发该异常。

按适用场景从开发调试到生产部署排序：

• 开发调试阶段最简方案：关闭Flask开发服务器的多线程模式，强制单线程处理请求，修改服务启动参数即可：

  if __name__ == '__main__':
      # 新增threaded=False参数关闭多线程
      app.run(debug=False, host='0.0.0.0', port=2233, threaded=False)
  

  该方案改造成本极低，缺点是单线程模式下接口并发能力差，不可用于生产环境。
• 兼容多线程模式的轻量方案：显式让R代码块返回空值，避免rpy2自动触发SexpClosure类型转换，修改接口内的R调用逻辑：

  @app.route('/test')
  def test():
      print("Mahdi: test")
      robjects.r('''
                  library(zoo)
                  print("Mahdi")
                  invisible(return(NULL))
              ''')
      return {"body": "Nothing"}, 200
  

  该方案不需要调整Flask运行模式，开发、测试环境均可使用，注意所有R调用代码块末尾都需要加空返回处理，避免遗漏转换触发点。
• 生产环境标准方案：使用进程级隔离的WSGI服务器部署服务，采用单线程多进程模式启动，每个worker进程维护独立的rpy2 R实例，从根源避免跨线程调用R的问题。以gunicorn为例，启动命令如下：

  gunicorn -w 4 --threads 1 -b 0.0.0.0:2233 app:app
  

  该方案既可以保证服务并发能力，又能彻底规避rpy2线程不安全、转换规则跨线程失效的问题。
• 转换规则补全方案：如果以上方案均不生效，可以在导入rpy2时显式加载默认转换规则，所有R调用包裹在转换上下文内执行，避免线程上下文中找不到转换规则：

  import rpy2.robjects as robjects
  from rpy2.robjects import default_converter
  from rpy2.robjects.conversion import localconverter
  
  # 接口内R调用写法
  @app.route('/test')
  def test():
      print("Mahdi: test")
      with localconverter(default_converter):
          robjects.r('''
                      library(zoo)
                      print("Mahdi")
                  ''')
      return {"body": "Nothing"}, 200
  

内容的提问来源于stack exchange，提问作者Abbas Jafari