将参数传递给Celery任务的on_failure方法

from celery import Celery

app = Celery('my_task', broker='redis://localhost:6379/0')

@app.task(bind=True)
def my_task(self, param1, param2):
    # 任务逻辑
    try:
        # 执行任务的代码
        result = param1 + param2
    except Exception as e:
        # 任务执行失败时调用on_failure方法
        self.on_failure(exc=e, task_id=self.request.id, args=(param1, param2))

@app.task(bind=True)
def my_task(self, param1, param2):
    try:
        # 执行任务的代码
        result = param1 + param2
    except Exception as e:
        # 任务执行失败时调用on_failure方法
        self.on_failure(exc=e, task_id=self.request.id, args=(param1, param2))

@app.task(bind=True)
def on_failure(self, exc, task_id, args, kwargs, einfo):
    # 记录任务执行失败的异常信息
    print(f"Task {task_id} failed with exception: {exc}")

from my_task import my_task

# 调用任务，并传递参数
result = my_task.apply_async(args=(10, 20))