在本篇文章里小编给大家来源gaodai#ma#com搞*!代#%^码网整理的是关于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
如图，接收到任务并成功执行。
以上就是本次介绍的全部相关知识点，感谢大家的学习和对gaodaima搞代码网的支持。
以上就是Django使用Celery加redis执行异步任务的实例内容的详细内容，更多请关注gaodaima搞代码网其它相关文章！
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：Django使用Celery加redis执行异步任务的实例内容
转载请注明原文链接：Django使用Celery加redis执行异步任务的实例内容
