码迷,mamicode.com
首页 > 其他好文 > 详细

Django使用Celery加redis执行异步任务

时间:2020-02-20 00:20:27      阅读:114      评论:0      收藏:0      [点我收藏+]

标签:djang   __name__   for   cti   mail   使用   image   write   项目   

 

 简单使用

安装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执行异步任务

标签:djang   __name__   for   cti   mail   使用   image   write   项目   

原文地址:https://www.cnblogs.com/viete/p/12332742.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!