INSTALLED_APPS = [
    'django.contrib.admin',
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.messages',
    'django.contrib.staticfiles',
    'djcelery',
    'demo'
]

# 导入tasks文件，如果使用autodiscover_tasks(见后)
# 则Celery在启动时，会自动检索每个app下的tasks.py，所以这个配置不是很必要
# 如果需要导入其他非tasks.py的任务，或者没有使用如果使用autodiscover_tasks
# 则需要再此配置需要导入的模块
# CELERY_IMPORTS = ('demo.tasks', )
# 配置 celery broker
CELERY_BROKER_URL = 'amqp://user:[email protected]:5672//'
# 配置 celery backend 用Redis会比较好
# 因为手上没有redis服务器，所以演示时用RabbitMQ替代
CELERY_RESULT_BACKEND = 'amqp://user:[email protected]:5672//'
# 声明队列，如果有需要为不同任务分配不同队列的需求，需要在配置文件中声明队列
# 这里声明了一个名为djcelery_demo的队列，routing_key为djcelery.demo
# 关于声明队列的参数及作用，详见celery的官方手册，这里不再赘述
from kombu import Queue
CELERY_QUEUES = (
    Queue('djcelery_demo', routing_key='djcelery.demo'),
)

from celery import Celery
from django.conf import settings

# 创建celery应用，proj保持和django项目名称一直
celery_app = Celery('proj', broker=settings.CELERY_BROKER_URL)
# 从配置文件中加载除broker外的其他配置
celery_app.config_from_object('django.conf:settings')
# 自动检索每个app下的tasks.py
celery_app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

import logging
from proj.celery import celery_app

@celery_app.task
def async_task():
    logging.info('run async_task')

from django.http import HttpResponse
from demo.tasks import async_demo_task

# Create your views here.
def demo_task(request):
	# delay表示将任务交给celery执行，具体的也烦请参考celery官方手册
    # 这里主要是对Django Celery的配置及可能遇到的问题进行说明和分享
    # 不会把太多的精力放在Celery的使用上
    async_demo_task.delay()
    return HttpResponse('任务已经运行')

from django.contrib import admin
from django.urls import path
from demo.views import demo_task

urlpatterns = [
    path('admin/', admin.site.urls),
    path('async_demo_task', demo_task),
]

from django.http import HttpResponse
from demo.tasks import async_demo_task

# Create your views here.
def demo_task(request):
	# delay表示将任务交给celery执行
    async_demo_task.delay()
    return HttpResponse('任务已经运行')

from django.contrib import admin
from django.urls import path
from demo.views import demo_task

urlpatterns = [
    path('admin/', admin.site.urls),
    path('async_demo_task', demo_task),
]

# 设定时区，配置计划任务时需要
CELERY_TIMEZONE = 'Asia/Shanghai'
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'

def add_task(request):
    interval = IntervalSchedule.objects.filter(every=30, period='seconds').first()
    periodic_task = PeriodicTask(name='test', task='demo.tasks.async_demo_task', interval=interval)
    periodic_task.save()
    return HttpResponse('任务已经添加')

urlpatterns = [
    path('admin/', admin.site.urls),
    path('async_demo_task', demo_task),
    path('add_task', add_task),
    path('get_periodic_task_list', get_periodic_task_list),
]

def get_periodic_task_list(request):
    """
    获取周期性任务列表
    :return:
    """
    periodic_task_list = PeriodicTask.objects.all()
    data = [model_to_dict(periodic_task) for periodic_task in periodic_task_list]
    resp = json.dumps(data, cls=CustomJSONEncoder, ensure_ascii=False)
    return HttpResponse(resp, content_type='application/json', status=200)