python celery定时任务(并行编程 33)

每10秒进行一次:task任务名称，schedule，秒数或者timedelta对象或者crontab对象.args参数，kwargs:字典参数,options：所有 apply_async 所支持的参数

import celery app = celery.Celery('cele', broker='redis://localhost:6379') @app.task def send(message): return message app.conf.beat_schedule = { 'send-every-10-seconds': { 'task': 'cele.send', 'schedule': 10.0, 'args': ('Hello World', ) }, }

添加定时任务的另外一种方式

from celery import Celery from celery.schedules import crontab app = Celery() @app.on_after_configure.connect def setup_periodic_tasks(sender, **kwargs): # Calls test('hello') every 10 seconds. sender.add_periodic_task(10.0, test.s('hello'), name='add every 10') # Calls test('world') every 30 seconds sender.add_periodic_task(30.0, test.s('world'), expires=10) # Executes every Monday morning at 7:30 a.m. sender.add_periodic_task( crontab(hour=7, minute=30, day_of_week=1), test.s('Happy Mondays!'), ) @app.task def test(arg): print(arg)

crontab的配置方式

from celery.schedules import crontab

每分钟执行一次：http://docs.celeryproject.org/en/latest/reference/celery.schedules.html#celery.schedules.crontab

c1 = crontab()

每天凌晨十二点执行

c2 = crontab(minute=0, hour=0)

每十五分钟执行一次

crontab(minute='*/15')

每周日的每一分钟执行一次

crontab(minute='',hour='', day_of_week='sun')

每周三，五的三点，七点和二十二点没十分钟执行一次

crontab(minute='*/10',hour='3,17,22', day_of_week='thu,fri')

############启动 celery -A cele beat