delay（）
在前面的篇章中调用任务，可使用delay()方法:
In [1]: from Celery_tasks.tasks import my_task1,my_task2,my_task3,my_task4
# 无传递参数的调用任务
In [2]: my_task1.delay()
Out[2]: <AsyncResult: 20d3ee91-d101-477a-9326-6dba394d8bda>
# 传递参数调用任务
In [2]: my_task4.delay(10,20)
Out[2]: <AsyncResult: 1d4fbd26-9fb1-4697-a0b1-9ba2d773596d>
apply_async()
也可以使用**apply_async()**方法，该方法可让我们设置一些任务执行的参数，例如，任务多久之后才执行，任务被发送到那个队列中等等.
查看一下当前celery的队列名称，如下：
In [9]: ret = my_task4.apply_async((2, 2))
In [10]: ret.result
Out[10]: 4
In [11]: ret.failed()
Out[11]: False
# 发送执行my_task4任务，参数为(2,2), 发送至celery队列，再10秒后开始执行
In [15]: ret = my_task4.apply_async((2, 2), queue='celery', countdown=10)
# 在10秒内查看结果，无结果显示，说明任务还未执行
In [16]: ret.result
In [17]:
# 在10秒后查看结果，有结果显示，说明任务已执行
In [17]: ret.result
Out[17]: 4
In [18]: ret.failed()
Out[18]: False
# 查看任务ID
In [19]: ret.task_id
Out[19]: '63c6e411-a8cd-4ccd-a9a9-7f6a23fb4f95'
任务my_task4将会被发送到celery队列中，并且在发送10秒之后执行。
如果我们直接执行任务函数，将会直接执行此函数在当前进程中，并不会向broker发送任何消息。
无论是delay()还是apply_async()方式都会返回AsyncResult对象，方便跟踪任务执行状态，但需要我们配置result_backend.
每一个被调用的任务都会被分配一个ID，我们叫Task ID.
原文始发于微信公众号（海洋的渔夫）：5. Django 2.1.7 Celery 4.3.0 调用任务Calling Task
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/35168.html
