如何在Python 2代码中使用仅支持Python 3的Redis OM库？

核心思路 #

借助execnet库创建Python 3的子进程网关，在子进程中执行Python 3代码调用目标库（如Redis OM），通过通信通道完成Python 2与Python 3进程间的数据交互，本质是让两个版本的Python进程独立运行、跨进程传递结果。

具体实现步骤 #

1. 准备环境依赖

   • 同时保留Python 2和Python 3的运行环境
   • 在Python 2环境下安装execnet：pip2 install execnet
   • 在Python 3环境下安装Redis OM：pip3 install redis-om

2. 示例代码
   以下是Python 2代码调用Python 3的Redis OM的完整示例：

   import execnet
   
   # 创建Python 3网关，替换为你的Python 3可执行文件路径（比如python3.9）
   gateway = execnet.makegateway("popen//python=python3")
   # 创建跨版本通信通道
   channel = gateway.remote_exec("""
       # 此代码块在Python 3环境中执行
       from redis_om import HashModel, get_redis_connection
   
       # 配置Redis连接
       redis = get_redis_connection(
           host="localhost",
           port=6379,
           db=0,
           decode_responses=True
       )
   
       # 定义Redis OM数据模型（示例）
       class Product(HashModel):
           name: str
           price: float
           quantity: int
   
           class Meta:
               database = redis
   
       # 执行Redis OM操作：创建并保存数据
       product = Product(name="无线耳机", price=299.9, quantity=50)
       product.save()
       # 查询刚保存的数据
       retrieved_product = Product.get(product.pk)
       
       # 将结果转为可序列化的字典，传回Python 2进程
       channel.send({
           "主键": retrieved_product.pk,
           "名称": retrieved_product.name,
           "价格": retrieved_product.price,
           "库存": retrieved_product.quantity
       })
   """)
   
   # 在Python 2中接收Python 3返回的结果
   result = channel.receive()
   print("从Redis OM获取的数据：", result)
   
   # 关闭网关释放资源
   gateway.exit()
   

3. 关键注意事项

   • 数据传递限制：execnet通道仅支持传递可序列化的基础数据类型（字典、列表、字符串、数字等），无法直接传递复杂对象，需在Python 3端先转为序列化格式再传回。
   • Python 3路径正确性：确保makegateway中指定的python3是系统中正确的Python 3可执行文件路径，若版本号明确（如python3.8）需对应修改。
   • 依赖环境隔离：Python 3环境必须单独安装好目标库，与Python 2的依赖完全分开，避免版本冲突。

内容的提问来源于stack exchange，提问作者wang larry