django celery 定時任務(windows平台)

這裡記錄下 django 利用celery 實現定時任務的方法

這裡首先注意下版本問題：

由於celery 4.0開始已經不支持 windows平台了, 可以在官網看到，所以這裡不能用最新的celery

版本如下：

windows10

Anaconda3

python:3.5

Django: 1.10.5

celery: 3.1.25

django-celery:3.2.1

以上均可用PIP 安裝,指定版本號即可

工程結構如下：

--project --project --__init__.py --setting.py --celery.py --url.py --.... --App1 --tasks.py --.... --APP2 --tasks.py --....

celery文件代碼如下：

from __future__ import absolute_import, unicode_literals import os from celery import Celery from django.conf import settings # set the default Django settings module for the celery program. os.environ.setdefault(DJANGO_SETTINGS_MODULE, project.settings)

app = Celery(project)

# Using a string here means the worker dont 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)

# Load task modules from all registered Django app configs.
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

@app.task(bind=True)
def debug_task(self):
print(Request: {0!r}.format(self.request))

__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]

settings.py 文件進行修改

BROKER_URL = django://localhost:8000// CELERYBEAT_SCHEDULER = djcelery.schedulers.DatabaseScheduler # Application definition

INSTALLED_APPS = [
django.contrib.admin,
django.contrib.auth,
django.contrib.contenttypes,
django.contrib.sessions,
django.contrib.messages,
django.contrib.staticfiles,
App1
kombu.transport.django,
djcelery,
]