DDR爱好者之家 Design By 杰米

简单使用

安装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执行异步任务的实例内容

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

DDR爱好者之家 Design By 杰米
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
DDR爱好者之家 Design By 杰米