data-verification/Statistical/celery_tasks.py

#-*- coding: utf-8 -*-
#__author__ = "dukun"


from datetime import timedelta
from celery import Celery
from celery.schedules import crontab

cel = Celery('tasks', broker='redis://127.0.0.1:6379/1', backend='redis://127.0.0.1:6379/2', include=[
    'channel_success_rate',
    'channel_use_time',
    'manage_data'
])
cel.conf.timezone = 'Asia/Shanghai'
cel.conf.enable_utc = False

cel.conf.beat_schedule = {
    # 名字随意命名
    'add-channel_rate-1-seconds': {
        # 执行tasks1下的test_celery函数
        'task': 'channel_success_rate.get_channel_rate',
        # 每隔2秒执行一次
        # 'schedule': 1.0,
         'schedule': crontab(minute="*/1")
        #'schedule': timedelta(seconds=6),
        # 传递参数
        #'args': ('张三',)
    },
    'add-channel_rate-2-seconds': {
         'task': 'channel_success_rate.get_channel_total_rate',
         'schedule': crontab(minute="*/1")
         #每年4月11号，8点42分执行
         #'schedule': crontab(minute=42, hour=8, day_of_month=11, month_of_year=4),
         #'args': ('张三',)
     },
     'add-channel_time-3-seconds': {
         'task': 'channel_use_time.get_channel_use_time',
         'schedule': crontab(minute="*/1")
     },
     'add-manage_data-4-seconds': {
         'task': 'manage_data.save_yesterday_data',
         'schedule': crontab(minute=10, hour=0)
     },
     'add-manage_data-5-seconds': {
         'task': 'manage_data.save_now_data',
         'schedule': crontab(minute="*/1")
     }

}