在celery作业和on_success函数中清除了SQLAlchemy会话

from celery import Celery
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

app = Celery('tasks')

# 创建数据库引擎和会话工厂
engine = create_engine('数据库连接字符串')
Session = sessionmaker(bind=engine)

@app.task
def my_task():
    session = Session()
    try:
        # 执行任务逻辑
        # ...
        session.commit()
    except Exception as e:
        session.rollback()
        raise e
    finally:
        session.close()

from celery import Celery
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker

app = Celery('tasks')

# 创建数据库引擎和会话工厂
engine = create_engine('数据库连接字符串')
Session = sessionmaker(bind=engine)

@app.task
def my_task():
    # 执行任务逻辑
    # ...

@app.task
def on_success_task(*args, **kwargs):
    session = Session()
    try:
        # 清理会话
        session.close()
    except Exception as e:
        session.rollback()
        raise e
    finally:
        session.close()

# 将on_success_task注册为on_success函数
app.conf.task_on_success = on_success_task