介绍一下如何调用任务,队列路由.
1. signature
我们到目前为止只是学习了如何使用delay()方法,当然这个方法也是非常常用的。但是有时我们并不想简单的将任务发送到队列中,我们想将一个任务函数(由参数和执行选项组成)作为一个参数传递给另外一个函数中,为了实现此目标,Celery使用一种叫做signatures的东西。
一个signature包装了一个参数和执行选项的单个任务调用。我们可将这个signature传递给函数。
我们先看下tasks.py模块中定义的任务函数:
from proj.celery import app as celery_app# 创建任务函数@celery_app.task
def my_task1():print("任务函数(my_task1)正在执行....")@celery_app.task# 2. Primitives这些primitives本身就是signature对象,因此它们可以以多种方式组合成复杂的工作流程。primitives如下:group: 一组任务并行执行,返回一组返回值,并可以按顺序检索返回值。chain: 任务一个一个执行,一个执行完将执行return结果传递给下一个任务函数.tasks.py模块如下:```python[Tornado 文档](https://www.tornadoweb.org/)[python-magic 文档](https://github.com/ahupp/python-magic)from proj.celery import app as celery_app# 创建任务函数[Sanic 文档](https://sanic.dev/)[rich 文档](https://rich.readthedocs.io/)[jsonschema 文档](https://python-jsonschema.readthedocs.io/)[openpyxl 文档](https://openpyxl.readthedocs.io/)@celery_app.task
def my_task1(a, b):print("任务函数(my_task1)正在执行....")return a + b@celery_app.task[PyTorch 文档](https://pytorch.org/)def my_task2(a, b):print("