Celery初步

创建任务

# tasks.py
from celery import Celery

app = Celery('tasks', broker = 'redis://localhost:6379/0')

@app.task
def add(x, y)
    return x + y

运行Celery职程服务器

celery -A tasks worker --loglevel=info

调用任务

from tasks import add
add.delay(4, 4)
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 序言第1章 并行和分布式计算介绍第2章 异步编程第3章 Python的并行计算第4章 Celery分布式应用第5章...
    SeanCheney阅读 14,323评论 3 35
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,388评论 19 139
  • 在学习Celery之前,我先简单的去了解了一下什么是生产者消费者模式。 生产者消费者模式 在实际的软件开发过程中,...
    c2db9ba35639阅读 8,854评论 0 8
  • 为了在后台运行任务,我们可以使用线程(或者进程)。使用线程(或者进程)的好处是保持处理逻辑简洁。但是,在需要可扩展...
    摸不去的尘阅读 12,172评论 0 20
  • 《飞越疯人院》影评 偶然一次机会,我观看了《飞越疯人院》这一部电影。该部电影讲述的是想要避免牢里苦力的麦克,装疯卖...
    南檀香阅读 1,586评论 0 0