celery的简单使用

• • • celery的运行逻辑
    • 遇到的问题
    • 以目录结构使用celery
    • celery接收返回值

celery中客户端中定义任务的函数代码和worker中实际执行的函数代码可以不相同，只要保证两者的函数名相同即可，其中在实际执行中使用的是worker中的函数代码

Task handler raised error: ValueError('not enough values to unpack (expected 3, got 0)

报错原因：win10调用celery4.x版本的时候会出现这样的问题
解决方法：
1> 安装eventlet

pip install eventlet

2> 启动worker的时候加个参数

celery -A task worker -l info -P eventlet

目录结构：
1> celery.py是启动文件：

from celery import Celery

# 定义celery对象
celery_app = Celery('order')
# 引入配置信息
celery_app.config_from_object('order.tasks.celery_config')
# 自动搜寻异步任务，指明包名后celery会自动找到包中的`tasks.py`文件
celery_app.autodiscover_tasks(['order.tasks.sms'])

2> celery_config.py是配置文件：

# 任务队列broker的存放位置
BROKER_URL = 'redis://127.0.0.1:6379/1'

# 结果数据backend的存放位置
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/2'

3> 包sms用于存放这个任务相关的文件，其中需要有一个task.py文件，在其中定义任务的函数代码，在启动程序时celery会自动寻找到包中的tasks.py文件，并执行其中的代码：

# tasks.py文件

from order.tasks.celery import celery_app
from order.libs.yuntongxun.sms import SSDK

@celery_app.task
def send_sms(tels, datas, temp_id):
    """发送短信的异步任务"""
    ssdk = SSDK()
    ssdk.send_message(tels, datas, temp_id)

4> 启动命令，启动启动文件以启动celery程序：

celery -A order.tasks.celery worker -l info

当celery的任务函数有返回值时，可以在客户端进行获取

# 使用celery异步发送短信，delay函数不会堵塞，将会立即返回
result = send_sms.delay([mobile], (sms_code, 5), '1')

print(result)  # 返回的异步执行的结果对象
print(result.id)  # 获取对象的id
# 通过get()方法能获取celery异步执行的结果
# get()方法默认是阻塞的行为，会等到有了执行结果之后才返回
# 可以通过参数timeout来设置超时时间，超时时间结束还拿不到结果则直接返回
ret = result.get()
print(ret)