python2--djnago xadmin 定时任务，手把手

INSTALLED_APPS = (
    ‘djcelery‘,

)


import djcelery

djcelery.setup_loader()
BROKER_URL = ‘redis://localhost:6379‘
CELERYBEAT_SCHEDULER = ‘djcelery.schedulers.DatabaseScheduler‘
CELERY_RESULT_BACKEND = ‘djcelery.backends.database:DatabaseBackend‘
CELERY_ACCEPT_CONTENT = [‘application/json‘]
CELERY_TASK_SERIALIZER = ‘json‘
CELERY_RESULT_SERIALIZER = ‘json‘
CELERY_TIMEZONE = ‘Asia/Shanghai‘
CELERY_LOG_FILE = os.path.join(os.path.join(os.path.join(BASE_DIR, ‘logs‘), ‘celery‘), ‘celery.log‘)
CELERYBEAT_LOG_FILE = os.path.join(os.path.join(os.path.join(BASE_DIR, ‘logs‘), ‘celery‘), ‘beat.log‘)
CELERY_TASK_RESULT_EXPIRES = 10

# -*- coding:utf-8 -*-
from __future__ import absolute_import,unicode_literals

from .celery import app as celery_app

__all__ = [‘celery_app‘]

import pymysql
pymysql.install_as_MySQLdb()

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

from __future__ import absolute_import,unicode_literals

import os
from celery import Celery, platforms
from django.conf import settings

# set the default Django settings module for the ‘celery‘ program.
os.environ.setdefault(‘DJANGO_SETTINGS_MODULE‘, ‘WebSite.settings‘)

# WebSite主应用名
app = Celery(‘WebSite‘)
platforms.C_FORCE_ROOT = True

app.config_from_object(‘django.conf:settings‘)
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

@app.task(bind=True)
def debug_task(self):
    print(‘Request: {0!r}‘.format(self.request))

app.conf.timezone = ‘UTC‘

# from datetime import timedelta
# app.conf.update(
#     CELERYBEAT_SCHEDULE = {
#         ‘task_add‘: {
#             ‘task‘: ‘apps.tasks.start_running‘,
#             ‘schedule‘: timedelta(seconds=10)
#         },
#     },
# )

# -*- coding:utf-8 -*-
from __future__ import absolute_import, unicode_literals
from djcelery.models import (
  TaskState, WorkerState,
  PeriodicTask, IntervalSchedule, CrontabSchedule,
)
import xadmin

xadmin.site.register(IntervalSchedule) # 存储循环任务设置的时间
xadmin.site.register(CrontabSchedule) # 存储定时任务设置的时间
xadmin.site.register(PeriodicTask) # 存储任务
xadmin.site.register(TaskState) # 存储任务执行状态
xadmin.site.register(WorkerState) # 存储执行任务的worker

# -*- coding:utf-8 -*-
from __future__ import absolute_import
from WebSite.celery import app
from celery import task, shared_task


@app.task
def start_running(info):
    print(info)
    print(‘--->>开始执行任务<<---‘)
    print(‘比如发送短信或邮件‘)
    print(‘>---任务结束---<‘)
@shared_task
def mul(x, y):
    print(‘乘法‘,x*y)
    return x * y