python3.6
django1.11.23
celery==3.1.25  异步任务
django-celery==3.2.2  定时任务管理包
redis==2.10.6
django-redis-cache==1.7.1 方便配置Redis缓存

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',)

#! /usr/bin/python3
# -*- coding:utf-8 -*-
# file: celery.py
# author: wangchenxi
# mail: wongchenxi@icloud.com
# brief:
# version: 0.1.00
# Create Time:2019-12-08 22:21:00
# Last Update: 2019-12-10 01:26:48 AM
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery, platforms
from django.conf import settings
from celery.schedules import crontab

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

app = Celery('wangchenxi_top')
# imports = ('api.tasks', 'blog.tasks')
platforms.C_FORCE_ROOT = True
# 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')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)


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

import djcelery
''''''
INSTALLED_APPS = [
    # ...
    'djcelery',
    # ....
]
TIME_ZONE = 'Asia/Shanghai'
USE_I18N = True
USE_L10N = True
USE_TZ = False

djcelery.setup_loader()
BROKER_URL = 'redis://127.0.0.1:6379'
CELERY_CONCURRENCY = 10
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379'
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'

from celery import shared_task
@shared_task
def task_hello_world(*args):
    '''
    xxxxxx
    '''
    pass
    return 'hello,world'

from api.tasks import task_hello_world
# 引入之后可以主动调用，发起异步任务，也可以通过配置的
# CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler' 发起任务调用
# 如果任务没有在views.py文件中引入则视为任务没有注册，进而不能通过CELERYBEAT_SCHEDULER完成调用

from api.tasks import task_hello_world

def every_where():
    '''
    xxxxx
    '''
    id = task_hello_world.delay(*args)
      #   如果需要返回结果需要记录id

python manage.py migrate
# 因为django-celery模块会去创建djcelery.schedulers.DatabaseScheduler
# 数据表

# 然后启动celery，同时启动beat
python manage.py celery multi start worker --loglevel=info --beat
# 如果不启动beat，则不能完成定时任务

#默认是0，就相当于是一个耗时循环
#CELERYBEAT_MAX_LOOP_INTERVAL= 0 
CELERYBEAT_MAX_LOOP_INTERVAL= 1