Django Celery定时任务

# -*-coding:utf-8 -*-

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from django.utils import timezone

# set the default Django settings module for the ‘celery‘ program.
env = os.environ.get(‘ENV‘)
#
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "main.settings")

app = Celery(‘celert-test‘)

# Using a string here means the worker doesn‘t have to serialize
# the configuration object to child processes.
# - namespace=‘CELERY‘ means all celery-related configuration keys
# should have a `CELERY_` prefix.
app.config_from_object(‘django.conf:settings‘, namespace=‘CELERY‘)

# Load task modules from all registered Django app configs.
app.autodiscover_tasks()

from __future__ import absolute_import, unicode_literals

# This will make sure the app is always imported when
# Django starts so that shared_task will use this app.
from .celery import app as celery_app

__all__ = (‘celery_app‘,)

# celery 配置
CELERY_BEAT_SCHEDULER = ‘django_celery_beat.schedulers:DatabaseScheduler‘
CELERY_TIMEZONE = ‘Asia/Shanghai‘ ## 使用亚洲/上海时区
CELERY_IGNORE_RESULT = True
#设置存储Celery任务队列的Redis数据库
CELERY_BROKER_URL = ‘redis://:pwd@host:prot/1‘ # Broker配置，使用Redis作为消息中间件
CELERY_ACCEPT_CONTENT = [‘json‘]
CELERY_TASK_SERALIZER = ‘json‘
#设置存储Celery任务结果的数据库
CELERY_RESULT_BACKEND = ‘redis://:pwd@host:prot/1‘ # BACKEND配置，这里使用redis
# CELERY_RESULT_BACKEND = ‘django-db‘
# 避免时区的问题
CELERY_ENABLE_UTC = False
DJANGO_CELERY_BEAT_TZ_AWARE = False

from django_celery_beat.models import IntervalSchedule, CrontabSchedule, PeriodicTask

class PeriodicTaskAdmin(object):
list_display = [
‘name‘, ‘task‘, ‘args‘, ‘kwargs‘, ‘queue‘,
‘exchange‘, ‘routing_key‘, ‘expires‘, ‘enabled‘,
‘last_run_at‘, ‘total_run_count‘, ‘date_changed‘, ‘description‘,
‘interval‘, ‘crontab‘, ‘solar‘, ‘clocked‘, ‘one_off‘,
‘start_time‘, ‘priority‘, ‘headers‘
]
ordering = [‘id‘]
search_fields = [‘name‘]
list_per_page = 10


class IntervalScheduleAdmin(object):
ordering = [‘id‘]
list_per_page = 10


class CrontabScheduleAdmin(object):
list_display = [
‘id‘,
‘minute‘,
‘hour‘,
‘day_of_week‘,
‘day_of_month‘,
‘month_of_year‘,
‘timezone‘
]
ordering = [‘id‘]
search_fields = [‘minute‘]
list_per_page = 10

#定时
xadmin.site.register(CrontabSchedule, CrontabScheduleAdmin)
xadmin.site.register(IntervalSchedule, IntervalScheduleAdmin)
xadmin.site.register(PeriodicTask, PeriodicTaskAdmin)

启动Celery
celery -A main worker -l info -P eventlet
启动定时任务
celery -A main beat -l info -S django