Celery-异步

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

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

引用函数库

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)

创建异步函数

@cel.task
def func1(name):
    print(f'测试celery框架--打印参数: {name}')

@cel.task
def func2(name):
    print(f'测试celery框架--打印参数: {name}')

添加任务

from test9 import func1, func2

relus = func1.delay('任务1')
print(relus.id)

relus2 = func2.delay('任务1')
print(relus2.id)

启动框架

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

执行添加