1. 使用RabbitMQ 代理（broker）在客戶端和工作執行者之間進行互動

http://www.rabbitmq.com/install-windows.html

安裝RabbitMQ 必須先下載安裝了erlang 才可以安裝RabbitMQ

2.使用pip安裝：

pip install kombu
pip install celery

pip install django-celery

一般選擇安裝了celery會一起安裝其他包，不用管其他的包，celery 的版本。celery4.0開始celery beat定時需要單獨安裝，

celery3.x.x則不需要重新安裝celery-beat,直接可以使用，

3.配置

首先在setting中匯入

import djcelery

app配置中加入djcelery,

在setting 底部加入

CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'
djcelery.setup_loader()
BROKER_URL = 'amqp://[email protected]//'
BROKER_POOL_LIMIT = 0
CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend'
BROKER_TRANSPORT_OPTIONS = {'visibility_timeout'
 
: 28800}

4.在setting所在的目錄下新建celery.py檔案加入程式碼：

from __future__ import absolute_import

import os
from django.conf import settings
from celery import Celery

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'web_cgcontrol.settings')


app = Celery('web_cgcontrol')
app.config_from_object('django.conf:settings'
 
)
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)


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

5.setting所在的目錄下，根__init__.py檔案下加入：

from .celery import app as celery_app

注：如果使用mysql,那麼其中的檔案為：

from .celery import app as celery_app
import pymysql

pymysql.install_as_MySQLdb()

6.編寫tasks.py。必須是tasks的名字：

@shared_task(track_started=True)
def get_state(url):
    state = requests.get(url, allow_redirects=False).status_code

return state

獲取網頁的狀態碼為例

使用python manage.py makemigrations,和 python manage.py migrate遷移資料庫，則建立了djcelery的很多表，

新增定時任務即可定時獲取網頁狀態碼