Django使用Celery加redis执行异步任务的实例内容
简单使用
安装celery及redis
定义celery任务
项目下新建tasks.py
fromceleryimportCelery
#创建一个Celery类的实例对象
app=Celery('celery_task.tasks',broker='redis://127.0.0.1:6379/8')
#定义任务函数
@app.task
defsend_register_active_email(message):
withopen("D:\\celery\\text.txt",'a')asf:
f.write("Toperformatask..."+message)
调用触发任务
run.py
fromcelery_tasks.tasksimportsend_register_active_email
defregister():
send_register_active_email.delay("test1\n")
if__name__=="__main__":
register()
在项目目录下启动celery
celery-Atasksworker-linfo
再运行run.py
如图，接收到任务并成功执行。
以上就是本次介绍的全部相关知识点，感谢大家的学习和对毛票票的支持。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。