python - 如何从@app.task获取celery.Task对象

Question

我有一个任务函数:

@app.task(base=ProcessingTask)
def do_processing_task(args):

ProcessingTask继承celery.Task:

class ProcessingTask(celery.Task):
    def on_success(self, res, task_id, args, kwargs):

我远程启动任务

result = app.send_task("workerTasks.do_processing_task", args=[args])

(我无法从调用此文件的服务器文件访问workerTasks文件，因此send_task是我需要采取的路线)

在 do_processing_task 中，我想获取ProcessingTask 对象的实例，以便我可以向其中添加一些可以在 do_processing_task::on_success 中使用的数据。

这可能吗？谢谢。

Answer 1

绑定(bind)任务

绑定(bind)任务意味着任务的第一个参数将始终是任务实例(自身)，就像 Python 绑定(bind)方法一样:

logger = get_task_logger(__name__)

@task(bind=True)
def add(self, x, y):
    logger.info(self.request.id)