我celery
在我的应用程序中使用来运行定期任务。让我们看下面的简单示例
from myqueue import Queue
@perodic_task(run_every=timedelta(minutes=1))
def process_queue():
queue = Queue()
uid, questions = queue.pop()
if uid is None:
return
job = group(do_stuff(q) for q in questions)
job.apply_async()
def do_stuff(question):
try:
...
except:
...
raise
正如您在上面的示例中看到的那样,我celery
曾经运行异步任务,但是(因为它是一个队列)我需要queue.fail(uid)
在出现异常do_stuff
或queue.ack(uid)
其他情况时执行此操作。在这种情况下,在这两种情况下从我的任务中获得一些回调将是非常清晰和有用的 -on_failure
和on_success
.
我看过一些文档,但从未见过将回调与apply_async
. 有可能这样做吗?