Celery + Pythonでは、task_revoked関数からタスクパラメータにアクセスするにはどうすればよいですか？

Question

私はセロリ内で実行中のタスクを終了した後、いくつかのものをクリーンアップしようとしています。

@app.task() 
def foo(bar, baz): 
    pass 

：タスクは次のように定義されている場合例えばので：どのように私は仕事関数が呼び出されたパラメータへのアクセスを得ることができ、タスク取り消された関数本体内部

1）：私は現在2つの問題点を打っています

コードの中でbarとbazにアクセスするにはどうすればよいですか？

2）私はタスクがX以外のものである場合にのみ、タスクを終了したいと思います。つまり、タスクを片手で調べ、もう一方の状態を設定することです。状態を検査することはできますが、私はタスク関数本体の中のコンテキストの周りに頭を上げるのが難しいです。

私はこのようなFOOを定義する場合：

@app.task(bound=True) 
def foo(self, bar, baz): 
    pass 

と言うから、それを呼び出す....フラスコのようなfoo(bar, baz)、その後、私はデコレータがないことを意味する、第三パラメータが期待されていることをエラーが発生します自己パラメータを通して自動的にコンテキストを追加しないでください。

アプリは、単にあなたが要求オブジェクトからタスクの引数を取得することができ、事前

Answer 1

でcelery.Celery()

のおかげであると定義されます。

from celery.signals import task_revoked 

@task_revoked.connect 
def my_task_revoked_handler(sender=None, body=None, *args, **kwargs): 
    print(kwargs['request'].args) 

これは、タスクに与えられた引数を出力します。

更新：

あなたはbindないboundを使用する必要があります。 http://docs.celeryproject.org/en/master/userguide/tasks.html#context：

@app.task(bind=True) 
def foo(self, bar, baz):