django中使用celery异步执行耗时长的任务

  • A+
所属分类:python
  • 每次修改完TASK需要重启worker:python manage.py celery worker --loglevel=info
  • 示例一的解决:将耗时的程序放到celery中执行
  • 示例二的解决:使用celery定时执行
名词
  • 任务task:就是一个Python函数
  • 队列queue:将需要执行的任务加入到队列中
  • 工人worker:在一个新进程中,负责执行队列中的任务
  • 代理人broker:负责调度,在布置环境中使用redis,也可以使用rabbitmq等
使用
  • 安装包(celery-with-redis对celery有版本需求,当执行安装celery-with-redis的时候如果版本不符合,会自动卸载celery并自动重装)

  • 配置settings

  • 在应用目录下创建task.py文件       

  • 迁移,生成celery需要的数据表
    python manage.py migrate
  • 启动Redis
    sudo redis-server /etc/redis/redis.conf
  • 启动worker
    python manage.py celery worker --loglevel=info
  • 调用语法
    function.delay(parameters)
  • 使用代码

  • 我的微信
  • 这是我的微信扫一扫
  • weinxin
  • 我的微信公众号
  • 我的微信公众号扫一扫
  • weinxin
admin

评论已关闭!

目前评论:1   其中:访客  0   博主  0   引用   1

    来自外部的引用: 1

    • django celery做定时任务 – 爱运维 | 爱运维