怎么在Django中使用Celery执行异步任务

这篇文章给大家介绍怎么在Django中使用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 -A tasks worker -l info

再运行run.py

如图，接收到任务并成功执行。

关于怎么在Django中使用Celery执行异步任务就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。