celery定時任務

時間 2019-11-06

標籤 celery 定時任務简体版

原文原文鏈接

from celery import Celery
from datetime import timedelta

app = Celery('gx', broker='redis://localhost:6379/1')
app.conf.update(
    CELERYBEAT_SCHEDULE={
        'perminute': {
            'task': 'gx.add',
            'schedule': timedelta(seconds=5),
            'args': (1, 2)
        }
    }
)


@app.task
def add(a, b):
    print(a+b)

　　先啓動worker：celery -A proj worker -l info -f=test.log (-f指定的是日誌輸出位置)python

　　而後啓動beat：celery -A proj beatredis

beat發起定時任務worker執行定時任務app