Python Celery与RabbitMQ结合操作

 0、RabbitMQ安装请参考另外一篇博客

https://www.cnblogs.com/ygbh/p/13461525.html

1、安装celery模式

# Celery + RabbitMQ
pip install "celery[librabbitmq]"

# Celery + RabbitMQ + Redis
pip install "celery[librabbitmq,redis,auth,msgpack]"

提示：

如果是在Window系统开发或运行测试需要进行如下操作，否则会报错：ValueError: not enough values to unpack (expected 3, got 0)

解决方法：
# 安装协程模块
pip  install eventlet

 2、编写第一个celery框架的程序

from celery import Celery

# 中间件，这里使用RabbitMQ，pyamqp://Uername:Password@IP:Port//v_host
broker_url = 'pyamqp://development:root@192.168.2.129:5672//development_host'

# 后端储存，这里使用RabbitMQ，rpc://Uername:Password@IP:Port//v_host
backend_url = 'rpc://development:root@192.168.2.129:5672//development_host'

# 实例化一个celery对象
app = Celery('tasks', broker=broker_url, backend=backend_url)

# 设置配置参数的文件，创建文件celeryconfig.py来配置参数
app.config_from_object('celeryconfig')


@app.task
def add(x, y):
    """
        求和的函数
    :param x:
    :param y:
    :return:
    """
    return x + y

tasks.py