django中celery的定时任务使用

from datetime import timedelta
from celery import Celery
import os
import django
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "自己的项目名.settings")
django.setup()
celery_app = Celery('mycelery')
#读取celery 的配置
celery_app.config_from_object('celery_task.config')
# 定时任务
                             # 文件夹名.文件名
celery_app.autodiscover_tasks(['celery_task.times'])
celery_app.conf.update(
    CELERYBEAT_SCHEDULE={
        'sum-task': {
             # 文件夹名.文件名.方法名
            'task': 'celery_task.times.my_con',
             # 多少秒执行一次（eg:5秒一执行）
            'schedule':  timedelta(seconds=5),
             # 这是传入my_con方法中的参数
            'args': (5, 6)
        },
        'sum-task1': {
            'task': 'celery_task.times.my_print',
            'schedule':  timedelta(seconds=3),
            'args': ()
        },
    }
)

"""
    celery 配置
"""
消息中间件 broker
BROKER_URL = 'redis://xx.xx.xx.xx:6379/11'
任务结果存储 results  backend
    CELERY_RESULT_BACKEND = 'redis://xx.xx.xx.xx:6379/12'
    # 时区
    CELERY_TIMEZONE = 'Asia/Shanghai'
    # 导入指定的任务模块
    CELERY_IMPORTS = (
        'celery_task.tasks'
    )

# 定时任务
import time
from celery_task import celery_app
@celery_app.task()
def my_con(x,y):
    print(x,y)
    print('x和y相加')
    return x+y
@celery_app.task()
def my_print():
    print('22222222')