【测试类型：驱动接口功能】【测试版本：7.0.0】 psycopg2驱动在使用eventlet的sqlalchemy引擎连接数据库时，报错segment fault

【标题描述】:psycopg2驱动在使用eventlet的sqlalchemy引擎场景下连接数据库，报错segment fault
【测试类型：驱动接口功能】【测试版本：7.0.0】 问题描述：psycopg2驱动在使用eventlet的sqlalchemy引擎场景下连接数据库，报错segment fault

【操作系统和硬件信息】(查询命令: cat /etc/system-release, uname -a):
![输入图片说明](https://foruda.gitee.com/images/1733475901393081183/a5375ed1_8409131.png "屏幕截图")

【测试环境】(单机/1主x备x级联备):单机

【被测功能】:驱动接口功能

【测试类型】:psycopg2驱动

【数据库版本】(查询命令: gaussdb -V):
gaussdb (openGauss 7.0.0-RC1 build 30d8cc0f) compiled at 2024-11-27 00:10:08 commit 0 last mr
【预置条件】:

【操作步骤】(请填写详细的操作步骤):
1. pip 安装 eventlet、sqlalchemy、gevent
2. 执行如下用例，连接数据库：需要先修改连接数据库信息

```
import psycopg2
import threading

import gevent,time
from gevent import monkey

from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import create_engine, MetaData, or_, join, outerjoin
from sqlalchemy import Column, String, Integer, Float, Boolean, DECIMAL
from sqlalchemy import Enum, Date, DateTime, Time, Text
from sqlalchemy import LargeBinary, UnicodeText, TIMESTAMP
from sqlalchemy import func, Table
from sqlalchemy import create_engine

import eventlet

# monkey.patch_all()
Base = declarative_base()
# 定义一个函数，用于创建SQLAlchemy引擎
def create_sqlalchemy_engine(database_uri):
    engine =  create_engine(database_uri, echo=False)
    Base.metadata.drop_all(engine)
    
# 定义一个函数，用于创建使用eventlet的SQLAlchemy引擎
def create_sqlalchemy_engine_with_eventlet(arg):
    # 使用eventlet的monkey patching来确保geventify所有的库
    database_uri = 'postgresql+psycopg2://admin:szoscar55!@10.1.0.75:27000/postgres'
    eventlet.monkey_patch()
    
    # 创建一个引擎，指定连接池大小和回收周期
    engine = create_engine(database_uri, echo=False, pool_size=10, pool_recycle=3600)
    Base.metadata.drop_all(engine)
    return engine
 
# 使用示例
# database_uri = 'dialect+driver://username:password@host:port/database'
database_uri = 'postgresql+psycopg2://aaaaa:xxxxx@xxxxxx/postgres'

import pdb
pdb.set_trace()
gevent.joinall([
    gevent.spawn(create_sqlalchemy_engine_with_eventlet,"https://www.python.org/"),
])
```

【预期输出】: 正常连接到数据库

【实际输出】: 报错segment fault
【原因分析】:
1. 这个问题的根因
2. 问题推断过程
3. 还有哪些原因可能造成类似现象
4. 该问题是否有临时规避措施
5. 问题解决方案
6. 预计修复问题时间

【日志信息】(请附上日志文件、截图、coredump信息):

【测试代码】:

openGauss/openGauss-connector-python-psycopg2

内容风险标识

评论 (5)

openGauss/openGauss-connector-python-psycopg2 .gitee-modal { width: 500px !important; }

内容风险标识