通过将 bind=True 设置为 @app.task 装饰器的参数,Celery 会自动将任务实例绑定到第一个参数(通常命名为 self),使得你可以在任务函数内部访问任务实例的属性和方法。
在 Celery 的任务函数中,self 参数代表任务实例本身。这个参数是通过 @app.task(bind=True) 装饰器的 bind=True 参数设置的。
任务实例的 self 参数提供了以下一些常用的属性和方法:
self.request:任务请求对象,包含了有关任务调用的详细信息,例如任务的 ID、参数等。你可以通过 self.request 来获取任务的相关信息,例如打印任务请求、记录任务调用等。
self.retry():用于在任务失败时重新尝试执行任务。你可以在任务函数内部使用 self.retry() 来触发任务的重新执行。
self.get():用于获取另一个异步任务的结果。你可以在任务函数内部使用 self.get() 来获取其他任务的执行结果。
通过使用 self 参数,任务函数可以访问任务实例的上下文和属性,从而更好地控制任务的行为和处理任务的结果。
需要注意的是,self 参数只在使用 @app.task(bind=True) 装饰器时才会出现,并且在任务函数的定义中,self 参数必须位于第一个位置。如果你不需要访问任务实例的属性和方法,可以省略 bind=True 参数,这样任务函数就不需要使用 self 参数。
总结起来,self 参数代表 Celery 任务的实例本身,通过 @app.task(bind=True) 装饰器进行绑定。通过 self,你可以在任务函数内部访问任务实例的属性和方法,例如任务请求、重新尝试任务等
@app.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))
在 Celery 中,上述代码定义了一个异步任务(Async Task),该任务使用 @app.task 装饰器进行修饰。具体来说:
@app.task(bind=True) 装饰器表示这是一个 Celery 任务,并且 bind=True 参数指定绑定任务实例到第一个参数(通常命名为 self),使得任务实例可以在任务内部访问。
def debug_task(self): 定义了一个名为 debug_task 的任务函数。这个函数接受一个参数 self,表示任务实例本身。在函数内部,可以通过 self 来访问任务的属性和方法。
print(‘Request: {0!r}’.format(self.request)) 打印了任务的请求信息。self.request 是一个包含有关任务的请求的特殊属性,其中包含有关任务调用的详细信息,例如任务的 ID、参数等。