Celery学习---Celery 与django结合实现计划任务功能
Posted ftl1012
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Celery学习---Celery 与django结合实现计划任务功能相关的知识,希望对你有一定的参考价值。
项目的目录结构:
项目前提: 安装并启动Redis
安装Django和Celery的定时任务插件
安装方法一: pip直接安装【安装了pip的前提下】
[email protected]:~$ pip3 install django-celery-beat
安装方法二:直接源安装
pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple django-celery-beat
CeleryTest/settings.py
INSTALLED_APPS = [ ... ‘app01‘, # 注册app ‘django_celery_beat‘, # Celery的定时任务和Django结合 ] MIDDLEWARE = [ ... # ‘django.middleware.csrf.CsrfViewMiddleware‘, ... ] STATICFILES_DIRS = (os.path.join(BASE_DIR, "statics"),) # 现添加的配置,这里是元组,注意逗号 TEMPLATES = [ ... ‘DIRS‘: [os.path.join(BASE_DIR, ‘templates‘)], ] # for celery CELERY_BROKER_URL = ‘redis://192.168.2.105‘, CELERY_BACKEND_URL = ‘redis://192.168.2.105‘, # 用于Celery的返回结果的接收
插件利用创建表来管理定时任务的
[email protected]:~/Celery/CeleryTest$ cd /home/omc/Celery/CeleryTest [email protected]:~/Celery/CeleryTest$ python3 manage.py migrate
CeleryTest/urls.py
from django.contrib import admin from django.urls import path from django.conf.urls import url, include from app01 import views urlpatterns = [ path(‘admin/‘, admin.site.urls), url(r‘index/‘, views.Index), ]
app01/tasks.py 文件名必须为tasks.py
# 文件名必须为tasks.py,Djaogo才能发现Celery from __future__ import absolute_import, unicode_literals from celery import shared_task # Django starts so that the @shared_task decorator (mentioned later) will use it: @shared_task # Django的各个App里都可以导入这个任务,否则只能在app01这个Django的App内使用 def add(x, y): return x + y @shared_task def mul(x, y): return x * y @shared_task def xsum(numbers): return sum(numbers)
CeleryTest/celery.py 文件名必须为celery.py
from __future__ import absolute_import, unicode_literals import os from celery import Celery # set the default Django settings module for the ‘celery‘ program. os.environ.setdefault(‘DJANGO_SETTINGS_MODULE‘, ‘CeleryTest.settings‘) app = Celery(‘CeleryTest‘) # Using a string here means the worker don‘t have to serialize # the configuration object to child processes. # - namespace=‘CELERY‘ means all celery-related configuration keys # should have a `CELERY_` prefix. app.config_from_object(‘django.conf:settings‘, namespace=‘CELERY‘) # Load task modules from all registered Django app configs. app.autodiscover_tasks() @app.task(bind=True) def debug_task(self): print(‘Request: {0!r}‘.format(self.request))
CeleryTest/__init__.py
from __future__ import absolute_import, unicode_literals # This will make sure the app is always imported when # Django starts so that shared_task will use this app. from .celery import app as celery_app __all__ = [‘celery_app‘]
上传文件到Linux服务器【Linux服务器需安装好Django服务】
需要Ubuntu下安装Django
pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple django
在Linux的后台启动任务:
[email protected]:~/Celery/CeleryTest$ python3 manage.py runserver 0.0.0.0:9000
在Linux的后台创建super用户:
[email protected]:~/Celery/CeleryTest$ cd /home/omc/Celery/CeleryTest [email protected]:~/Celery/CeleryTest$ python3 manage.py createsuperuser
在Win7下浏览器访问:
http://192.168.2.105:9000/admin/
在admin页面里,多了4张表
添加存储计划:页面之间添加即可
Intervals表创建一个10秒的任务
添加一个periodictask任务
注意:到此只是存储了一个定时计划而已,执行不了
Celery-beat调度器从Django内读取任务后发布给Celery的worker去执行
Linux后台启动Celery的worker
[email protected]:~/Celery/CeleryTest$ cd /home/omc/Celery/CeleryTest [email protected]:~/Celery/CeleryTest$ celery -A CeleryTest worker -l info
启动Celery-beat的调度器:从django内读取定时任务让后台worker执行
[email protected]:/etc/redis$ cd /home/omc/Celery/CeleryTest/ [email protected]:~/Celery/CeleryTest$ celery -A CeleryTest beat -l info -S django
右侧定时调取,左侧执行任务
简单梳理一下:后台上传Django和Celery整合后的文件,配置好Celery-beat后,在Linux后台启动Django项目,从Win7下访问admin进入页面后有一个定时任务的配置页面,配置好了页面的定时任务后,在Linux后台启动Celery的worker, 启动Celery-beat的调度器。此时调度器从Django内的schedule表中获取任务同时调用Celery的worker去执行任务,从而达到定时执行任务的效果。
问题解决
跨机器访问[Win7访问Linux下Django服务]:
问题现象一:直接无法访问:
# 9000端口仅仅监测本机的连接 [email protected]:~$ netstat -an|grep 9000
问题定位: Django启动方式错误
问题解决: 重新启动Django项目
错误的:python3 manage.py runserver 9000 【少了定向IP】 正确的:python3 manage.py runserver 0.0.0.0:9000
问题现象二:Win7下访问Linux下的Django和Celery结合的项目
问题解决:
更改settings.py里面的ALLOWED_HOSTS配置后重启服务
ALLOWED_HOSTS = [‘*‘] # 所有都可以访问
问题二:
问题现象: AttributeError: module ‘CeleryTest‘ has no attribute ‘celery‘
问题定位: 1.未进入到项目内,所以无法找到命名为celery的文件
2.项目内没有一个命名为celery.py的文件
以上是关于Celery学习---Celery 与django结合实现计划任务功能的主要内容,如果未能解决你的问题,请参考以下文章
Celery学习--- Celery 最佳实践之与django结合实现异步任务
django+django-celery+celery的整合实战
Celery 3 版本 定时执行与 异步执行 | Django 案例