python - 在 Django Celery 中，我如何判断任务是否已异步执行

Question

如果仅从 apply 方法而不是 apply_async （或 delay ）调用了该任务，我如何从 celery 任务中分辨出来。

Answer 1

您可以查看任务中的is_eagerorcalled_directly属性self.request（文档目前对区别不是很清楚）：

@app.task(bind=True)
def task_with_context(self, *args, **kwargs):
    print self.request.is_eager, self.request.called_directly