私のPythonコードに何か問題がありますか？ （関数）

Question

#tasks.py 
from celery.decorators import task 

@task() 
def add(x, y): 
    add.delay(1, 9) 
    return x + y 

>>> import tasks 
>>> res = tasks.add.delay(5, 2) 
>>> res.result() 
7 

このコードを実行すると、タスクがキューに継続的に追加されることが予想されます。しかし、そうではありません！最初のタスク（5,2）だけがキューに追加され、処理されます。

を継続的原因この行に、追加されているタスクがあるはずです：「add.delay（1,9）」

注：私は別のタスクを実行するために、各タスクを必要としています。

Answer 1

私が見ることができる限り、periodic_taskデコレータはプリオジックなタスクを作成しています。タスクはタスクを1つだけ作成します。そして、遅延はそれを非同期的に実行します。

再帰の代わりにperiodic_taskを使用するだけです。

Answer 2

add機能体内は、装飾されたバージョンではなく、元の機能を参照します。

タスクを繰り返し実行する必要がある場合は、代わりに@periodic_taskを使用してください。遅延が毎回異なる場合にのみ、再帰が必要です。この場合、デコレータを使用する代わりにサブクラスTaskを使用すると、問題なく再帰を使用できるようになります。

Answer 3

あなたはあなたが

http://celeryproject.org/docs/userguide/tasksets.html