python - celery 中 bind = True 关键字的含义是什么？

Question

下面celery代码中的bind=True是什么意思？何时使用，何时不使用？

@app.task(bind=True)
def send_twitter_status(self, oauth, tweet):
    try:
        twitter = Twitter(oauth)
        twitter.update_status(tweet)
    except (Twitter.FailWhaleError, Twitter.LoginError) as exc:
        raise self.retry(exc=exc)

Answer 1

只是对其他答案的一小部分补充。如前所述，bound tasks有权访问任务实例。需要这样做的一个用例是重试:

@celery.task(bind=True, max_retries=5)
def retrying(self):
    try:
        return 1/0
    except Exception:
        self.retry(countdown=5)

另一个用例是当您想要定义 custom states 时为您的任务并能够在任务执行期间设置它:

@celery.task(bind=True)
def show_progress(self, n):
    for i in range(n):
        self.update_state(state='PROGRESS', meta={'current': i, 'total': n})