Django使用Celery加redis执行异步任务的实例内容
简单使用
安装celery及redis
定义celery任务
项目下新建tasks.py
from celery import Celery
# 创建一个Celery类的实例对象
app = Celery('celery_task.tasks', broker='redis://127.0.0.1:6379/8')
# 定义任务函数
@app.task
def send_register_active_email(message):
with open("D:\\celery\\text.txt", 'a') as f:
f.write("To perform a task..." + message)
调用触发任务
run.py
from celery_tasks.tasks import send_register_active_email
def register():
send_register_active_email.delay("test1\n")
if __name__ == "__main__":
register()
在项目目录下启动celery
celery -A tasks worker -l info
再运行run.py
如图，接收到任务并成功执行。
以上就是本次介绍的全部相关知识点，感谢大家的学习和对软件开发网的支持。
您可能感兴趣的文章:django celery redis使用具体实践
相关文章
Shirley
2020-05-10
Faith
2023-07-20
Laila
2023-07-20
Hana
2023-07-20
Tia
2023-07-20
Chipo
2023-07-20
Meta
2023-07-20
Jacinthe
2023-07-20
Winona
2023-07-20
Lillian
2023-07-20
Rochelle
2023-07-20
Wanda
2023-07-20
Ophelia
2023-07-20
Rayna
2023-07-20
Agnes
2023-07-20
Kara
2023-07-20
Winola
2023-07-21