如何通过Django结合Celery与Redis实现异步任务实例操作？

本文共计217个文字，预计阅读时间需要1分钟。

简单使用 Celery 和 Redis，定义 Celery 任务，项目下新建 tasks.py，导入 Celery：from celery import Celery

简单使用

安装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

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

以上就是本次介绍的全部相关知识点，感谢大家的学习和对易盾网络的支持。