爬蟲由于其特殊性，可能需要定時(shí)做增量抓取，也可能需要定時(shí)做模擬登陸，以防止cookie過(guò)期，而celery恰恰就實(shí)現(xiàn)了定時(shí)任務(wù)的功能。在上述基礎(chǔ)上，我們將`tasks.py`文件改成如下內(nèi)容

　　from celery import Celery

　　app = Celery('add_tasks', broker='redis:''//223.129.0.190:6379/2', backend='redis:''//223.129.0.190:6379/3')

　　app.conf.update(

　　# 配置所在時(shí)區(qū)

　　CELERY_TIMEZONE='Asia/Shanghai',

　　CELERY_ENABLE_UTC=True,

　　# 官網(wǎng)推薦消息序列化方式為json

　　CELERY_ACCEPT_CONTENT=['json'],

　　CELERY_TASK_SERIALIZER='json',

　　CELERY_RESULT_SERIALIZER='json',

　　# 配置定時(shí)任務(wù)

　　CELERYBEAT_SCHEDULE={

　　'my_task': {

　　'task': 'tasks.add', # tasks.py模塊下的add方法

　　'schedule': 60, # 每隔60運(yùn)行一次

　　'args': (23, 12),

　　}

　　}

　　)

　　@app.task

　　def add(x, y):

　　return x + y

　　然后先通過(guò)`ctrl+c`停掉前一個(gè)worker，因?yàn)槲覀兇�碼改了，需要重啟worker才會(huì)生效。我們?cè)俅我訿celery -A tasks worker -l info`這個(gè)命令開啟worker。

　　這個(gè)時(shí)候我們只是開啟了worker，如果要讓worker執(zhí)行任務(wù)，那么還需要通過(guò)beat給它定時(shí)發(fā)送，我們?cè)匍_一個(gè)命令行，切換到項(xiàng)目根目錄，通過(guò)

　　celery beat -A tasks -l info

　　celery beat v3.1.25 (Cipater) is starting.

　　__ - ... __ - _

　　Configuration ->

　　. broker -> redis://223.129.0.190:6379/2

　　. loader -> celery.loaders.app.AppLoader

　　. scheduler -> celery.beat.PersistentScheduler

　　. db -> celerybeat-schedule

　　. logfile -> [stderr]@%INFO

　　. maxinterval -> now (0s)

　　[2017-05-19 15:56:57,125: INFO/MainProcess] beat: Starting...

　　這樣就表示定時(shí)任務(wù)已經(jīng)開始運(yùn)行了。