Python全系列 教程
3567个小节阅读:5930.1k
目录
鸿蒙应用开发
C语言快速入门
JAVA全系列 教程
面向对象的程序设计语言
Python全系列 教程
Python3.x版本,未来主流的版本
人工智能 教程
顺势而为,AI创新未来
大厂算法 教程
算法,程序员自我提升必经之路
C++ 教程
一门通用计算机编程语言
微服务 教程
目前业界流行的框架组合
web前端全系列 教程
通向WEB技术世界的钥匙
大数据全系列 教程
站在云端操控万千数据
AIGC全能工具班
A A
White Night
xxxxxxxxxx
pip install celery==5.2.7
pip install redis==4.3.4
xxxxxxxxxx
from celery import Celery
import time
app = Celery('tasks', broker='redis://127.0.0.1:6379/1', backend='redis://127.0.0.1:6379/2')
# 装饰器意思:这个函数是一个异步任务,扔到队列里面去
@app.task
def send_email(name):
print(f'准备执行任务:{name}')
print('执行任务中...')
time.sleep(5)
print(f'执行任务完成:{name}')
return 'OK1!'
@app.task
def send_msg(name):
print(f'准备执行任务:{name}')
print('执行任务中...')
time.sleep(5)
print(f'执行任务完成:{name}')
return 'OK2!'
xxxxxxxxxx
celery -A 可执行的任务文件 worker --loglevel=INFO --concurrency=并发的数量
注意
windows平台,可能会报错,也可能不报错,但不执行任务
解决方案
指定要执行的工具eventlet
xxxxxxxxxx
pip install eventlet==0.33.1
启动命令改为
xxxxxxxxxx
celery -A 可执行的任务文件 worker --loglevel=INFO --concurrency=并发的数量 -P eventlet
实时效果反馈
1. 关于Celery配置,说法错误的是?
A Celery无论异步任务还是定时任务,都要开启work
B 定义的任务需要使用task装饰器标识
C 启动work默认是开启10个并发
D Celery5.2.7对Windows默认不支持
答案
1=>C