Python之Celery笔记讲解第4篇:1. signature

举报
程序员一诺python 发表于 2025/08/10 19:04:33 2025/08/10
【摘要】 1. 问题抛出 celery介绍 1.RabbitMQ 2.Redis 1.创建应用 2.调用任务 3.存储结果 1.直接通过app来配置 2.专有配置文件 1. signature 指定任务发到那个队列中 配置周期性任务, 或者定时任务 周期执行任务 为celery设置环境变量 配置应用 设置app自动加载任务 从已经安装的app中查找任务 加上app对象的task装饰器 此

介绍一下如何调用任务,队列路由.

1. signature

我们到目前为止只是学习了如何使用delay()方法,当然这个方法也是非常常用的。但是有时我们并不想简单的将任务发送到队列中,我们想将一个任务函数(由参数和执行选项组成)作为一个参数传递给另外一个函数中,为了实现此目标,Celery使用一种叫做signatures的东西。

一个signature包装了一个参数和执行选项的单个任务调用。我们可将这个signature传递给函数。

我们先看下tasks.py模块中定义的任务函数: ```python 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 文档]

[python-magic 文档]

from proj.celery import app as celery_app

创建任务函数

[Sanic 文档]

[rich 文档]

[jsonschema 文档]

[openpyxl 文档]

@celery_app.task def my_task1(a, b): print("任务函数(my_task1)正在执行....") return a + b

@celery_app.task

[PyTorch 文档]

def my_task2(a, b): print("

【声明】本内容来自华为云开发者社区博主,不代表华为云及华为云开发者社区的观点和立场。转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。