首页 > 代码库 > 基础入门_Python-模块和包.深入Celery之Beat触发定时/周期性任务?
基础入门_Python-模块和包.深入Celery之Beat触发定时/周期性任务?
任务调度:
1. Celery默认任务单元由任务生产者触发,但有时可能需要其自动触发,而Beat进程正是负责此类任务,能够自动触发定时/周期性任务.
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Date : 2016-12-24 17:32:54 # @Author : 李满满 (xmdevops@vip.qq.com) # @Link : http://xmdevops.blog.51cto.com/ # @Version : $Id$ from __future__ import absolute_import # 说明: 导入公共模块 from datetime import timedelta from kombu import Queue, Exchange from celery.schedules import crontab # 说明: 导入其它模块 # BROKER_URL = ‘amqp://root:qwertyuiop@172.24.10.1:5672//‘ # CELERY_RESULT_BACKEND = ‘redis://172.24.10.1:6379/0‘ BROKER_URL = ‘amqp://root:qwertyuiop@10.2.5.51:5672//‘ CELERY_RESULT_BACKEND = ‘redis://10.2.5.51:5123/0‘ CELERY_TASK_SERIALIZER = ‘msgpack‘ CELERY_RESULT_SERIALIZER = ‘json‘ CELERY_TASK_RESULT_EXPIRES = 60 * 60 * 24 CELERY_ACCEPT_CONTENT = [‘json‘, ‘msgpack‘] CELERYD_MAX_TASKS_PER_CHILD = 40 CELERYBEAT_SCHEDULE = { ‘send_mail‘: { ‘task‘: ‘work.notify.email.send_mail‘, # ‘schedule‘: timedelta(minute=1), ‘schedule‘: crontab(minute=‘*/1‘), ‘args‘: (‘usr‘, ‘sub‘, ‘msg‘) } }
说明: 任务调度主要是为了解决业务场景中定时或周期任务,分别使用timedelta和crontab来定义计划任务,crontab的精度无法精确到秒时可使用timedelta代替,CELERYBEAT_SCHEDULE下可以定义多个计划/周期任务,send_mail为任务名称,task为任务单元导入名,schedule为具体调度,args为任务单元的参数.
注意: 运行时可先启动work进程池(celery worker -A work.app -l info)然后再启动beat进程池(celery beat -A work.app -l info),观察会发现beat进程每分钟生成一个任务,work进程发现任务后立即执行
扩展: Django-celery可实现在管理后台添加,删除,更新任务,是因为它使用了自定义的调度类djcelery.schedulers.DatabaseScheduler,Flask没有所以可以参考它来完成同样的功能.
本文出自 “满满李 - 运维开发之路” 博客,请务必保留此出处http://xmdevops.blog.51cto.com/11144840/1886696
基础入门_Python-模块和包.深入Celery之Beat触发定时/周期性任务?
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。