【云原生 | 28】Docker运行分布式任务处理平台Celery

作者简介：🏅云计算领域优质创作者🏅新星计划第三季python赛道第一名🏅 阿里云ACE认证高级工程师🏅
✒️个人主页：小鹏linux
💊个人社区：小鹏linux（个人社区）欢迎您的加入！

目录

1. 关于Celery

2.  Celery的架构图

3. 在linux中安装 Celery

 4. 在windows安装Celery

  👑👑👑结束语👑👑👑

---

1. 关于Celery

 Celery支持不同的并发和序列化的手段

并发：Prefork, Eventlet, gevent, threads/single threaded
序列化：pickle, json, yaml, msgpack. zlib, bzip2 compression， Cryptographic message signing 等等

2.  Celery的架构图

3. 在linux中安装 Celery

# 本机Python环境为Python3.7.4
pip install celery
 
# 验证安装 查看版本
celery --version
 
---console---
5.2.3 (dawn-chorus)

pip install redis

 4. 在windows安装Celery

pip install celery
pip install eventlet
 
# 验证安装 查看版本
celery --version
 
---console---
5.2.3 (dawn-chorus)

 5. 在Docker中部署Celery

$ docker run --link some-rabbit:rabbit --name some-celery -d celery:latest

$ docker run --link some-rabbit:rabbit --rm celery celery status

$ docker run --link some-redis:redis -e CELERY_BROKER_URL=redis://redis --name some-celery -d celery

$ docker run --link some-redis:redis -e CELERY_BROKER_URL=redis://redis --rm celery celery status

from celery import Celery 
app = Celery('hello', broker='amqp://guest@localhost//') 
@app.task 
def hello(): 
    return 'hello world'

  👑👑👑结束语👑👑👑