环境准备
Python3.6
pip install Django==2.0.1
pip install celery==4.1.0
pip install eventlet (加入协程支持)
安装erlang和rabbitMQ-server
配置settings.py文件
在settings.py文件中添加如下内容
... LANGUAGE_CODE = 'zh-hans' TIME_ZONE = 'Asia/Shanghai' USE_I18N = True USE_L10N = True USE_TZ = False CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672'
在settings.py同级目录创建celery.py
celery.py
注意替换: project_name
# -*- coding: utf-8 -*- from __future__ import absolute_import, unicode_literals import os from celery import Celery # 设置环境变量 os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project_name.settings') # 注册Celery的APP app = Celery('project_name') # 绑定配置文件 app.config_from_object('django.conf:settings', namespace='CELERY') # 自动发现各个app下的tasks.py文件 app.autodiscover_tasks()
修改settings.py同级目录的init.py文件
from __future__ import absolute_import, unicode_literals from .celery import app as celery_app __all__ = ['celery_app']
在某个APP中创建tasks.py文件
tasks.py
# -*- coding: utf-8 -*- from celery.task import task # 自定义要执行的task任务 @task def print_hello(): return 'hello celery and django...'
配置周期性任务或定时任务
再次编辑settings.py文件,添加如下内容
定时任务的配置格式参考:http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html
from celery.schedules import crontab CELERY_BEAT_SCHEDULE = { # 周期性任务 'task-one': { 'task': 'app.tasks.print_hello', 'schedule': 5.0, # 每5秒执行一次 # 'args': () }, # 定时任务 'task-two': { 'task': 'app.tasks.print_hello', 'schedule': crontab(minute=0, hour='*/3,10-19'), # 'args': () } }
启动worker和定时任务
启动worker (切换到manage.py同级目录下执行)
celery -A project_name worker -l info -P eventlet
启动定时任务或周期性任务
celery -A project_name beat -l info
这里备注一下:最好使用supervisord来管理上面这2条命令
存放任务结果的扩展
pip install django-celery-results Install APP INSTALLED_APPS = ( ..., 'django_celery_results', )
生成数据库表:python manage.py migrate django_celery_results
配置settings:CELERY_RESULT_BACKEND = 'django-db' (用数据库存放任务执行结果信息)
以上这篇Python Django2.0集成Celery4.1教程就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件!
如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
白云城资源网 Copyright www.dyhadc.com
暂无“Python Django2.0集成Celery4.1教程”评论...
更新日志
2024年11月13日
2024年11月13日
- 群星.1996-风月电影原声带【滚石】【WAV+CUE】
- Blast Slam S1参赛名单出炉:XG被直邀
- 《英雄联盟》Doinb想让Tian当教练:世纪大和解?
- 《忆蚀》Subliminal:揭秘后室之谜,路知行献声Weplay文化展
- 那英《征服NEWXRCD台湾版》日本压制[WAV+CUE]
- 群星《金曲百分百上》3CD(香港版)[WAV+CUE]
- 刘欢《雨中的树(新歌加精选)2CD》德国HD24K金碟[WAV+CUE]
- 郑源 《世间情歌》6N纯银SQCD[WAV+CUE][1G]
- 群星《粤潮2HQII》头版限量编号[低速原抓WAV+CUE][991M]
- 群星《2023好听新歌21》十倍音质 U盘音乐[WAV分轨][1G]
- 《热血传奇》双11感恩回馈 超值狂欢30天
- 原神5.2版本活动汇总 5.2版本活动有哪些
- 张敬轩.2010-NO.ELEVEN【环球】【WAV+CUE】
- 黄丽玲.2006-失恋无罪【艾回】【WAV+CUE】
- 阿达娃.2024-Laluna【W8VES】【FLAC分轨】