Celery-异步

Celery-异步

• • • 1.创建一个简单的celery任务

1.创建一个简单的celery任务

安装依赖
安装redis点击此连接

pip install celery
pip install eventlet 

windows下使用celery需要先安装pip install eventlet 否则会报错

引用函数库

import celery
import time

配置celery参数

broker = 'redis://127.0.0.1:6379/0'
backend = 'redis://127.0.0.1:6379/1'

cel = celery.Celery('tes', broker=broker, backend=backend)

创建异步函数-celery_task.py

import celery

broker = 'redis://127.0.0.1:6379/0'
backend = 'redis://127.0.0.1:6379/1'

cel = celery.Celery('tes', broker=broker, backend=backend)

@cel.task
def func1(name):
    print(f'执行给用户-【{name}】-发短信任务')


@cel.task
def func2(name):
    print(f'执行给用户-【{name}】-发邮件任务')

添加任务-produce_task.py

from celery_task import func1, func2

relus1 = func1.delay('张三')
print(relus1.id)

relus2 = func2.delay('张三')
print(relus2.id)

启动框架

celery -A test9  worker --loglevel=info -P eventlet

执行添加任务文件