前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >python celery定时任务(并行编程 33)

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

作者头像
用户5760343
发布2019-07-30 10:50:45
1.5K0
发布2019-07-30 10:50:45
举报
文章被收录于专栏:sktj

每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

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019.07.28 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 每10秒进行一次:task任务名称,schedule,秒数或者timedelta对象或者crontab对象.args参数,kwargs:字典参数,options:所有 apply_async 所支持的参数
    • 添加定时任务的另外一种方式
      • crontab的配置方式
      • 每分钟执行一次:http://docs.celeryproject.org/en/latest/reference/celery.schedules.html#celery.schedules.crontab
      • 每天凌晨十二点执行
      • 每十五分钟执行一次
      • 每周日的每一分钟执行一次
      • 每周三,五的三点,七点和二十二点没十分钟执行一次
      领券
      问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档