利用多线程/多处理将数据插入到sqlalchemy数据库中

import threading
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

# 创建数据库连接
engine = create_engine('数据库连接字符串')
Session = sessionmaker(bind=engine)

# 定义数据插入函数
def insert_data(data):
    # 创建数据库会话
    session = Session()

    try:
        # 插入数据到数据库
        session.add(data)
        session.commit()
    except Exception as e:
        session.rollback()
        raise e
    finally:
        session.close()

# 定义数据插入任务
class InsertTask(threading.Thread):
    def __init__(self, data):
        super().__init__()
        self.data = data

    def run(self):
        insert_data(self.data)

# 创建多个数据插入任务
data_list = [data1, data2, data3, ...]  # 数据列表
threads = []
for data in data_list:
    task = InsertTask(data)
    threads.append(task)

# 启动所有任务
for thread in threads:
    thread.start()

# 等待所有任务完成
for thread in threads:
    thread.join()