celery - セロリ タスク クラス内 run メソッド get task_id

Question

次のコードを実行しようとしています:

class myTask(Task):
    def run():
        print myTask.request.id

しかし、このコードは request_id として None を与えています。サイド セロリ タスク クラスで ID を読み取れない理由を説明してください

Answer 1

オブジェクト インスタンスではなく、クラスのリクエスト オブジェクトにアクセスしようとしています。これを試して：

class myTask(Task):
    def run(self, *args, **kwargs):
        print self.request.id

@taskデコレータを使用することもできます:

app = Celery('tasks', broker='amqp://guest@localhost//')

@app.task(bind=True)
def myTask(self):
    print self.request.id