目录

• 简介
• 核心
• 功能
• web框架集成
• 安装
• broker
• • rabbitmq

简介

celery是基于python的分布式任务队列，一款简单、灵活、可靠的分布式系统。可以在一台机器上运行，也可以在多台机器上运行。
任务队列一般用于线程或计算机之间分配工作的一种机制。

核心

task， 耗时的任务、定时任务
broker， 消息中间件，如redis/rabbitmq
worker, 执行者，并发执行（eventlet，gevent）
backend， 存储任务的结果，如redis/memcached/Django ORM
beat， 定时任务的调度器

功能

1. 监控集群状态
2. 任务调度
3. 内存泄漏保护

web框架集成

flask，
django,

安装

pip install celery==4.4.7

# 同时安装依赖
pip install 'celery[gevent]'
pip install 'celery[redis]'

broker

rabbitmq

生产环境中的首先

# 只需简单配置
broker_url = 'amqp://myuser:mypassword@localhost:5672/myvhost'

rabbitmq官网

Ubuntu安装：

$ sudo apt-get install rabbitmq-server

docker运行：

$ docker run -d -p 5462:5462 rabbitmq

https://www.celerycn.io/ru-men/celery-chu-ci-shi-yong