三、Celery执行定时任务

设定时间让celery执行一个 定时任务，product_task.py

from celery_task import send_email

from datetime import datetime

# 方式一

# v1 = datetime(2020, 3, 11, 16, 19, 00)

# print(v1)

# v2 = datetime.utcfromtimestamp(v1.timestamp())

# print(v2)

# result = send_email.apply_async(args=["egon",], eta=v2)

# print(result.id)

# 方式二

ctime = datetime.now()

# 默认用utc时间

utc_ctime = datetime.utcfromtimestamp(ctime.timestamp())

from datetime import timedelta

time_delay = timedelta(seconds=10)

task_time = utc_ctime + time_delay

# 使用apply_async并设定时间

result = send_email.apply_async(args=["egon"], eta=task_time)

print(result.id)

多任务结构中celery.py修改如下：

from datetime import timedelta

from celery import Celery

from celery.schedules import crontab

cel = Celery('tasks', broker='redis://127.0.0.1:6379/1', backend='redis://127.0.0.1:6379/2', include=[

    'celery_tasks.task01',

    'celery_tasks.task02',

])

cel.conf.timezone = 'Asia/Shanghai'

cel.conf.enable_utc = False

cel.conf.beat_schedule = {

    # 名字随意命名

    'add-every-10-seconds': {

        # 执行tasks1下的test_celery函数

        'task': 'celery_tasks.task01.send_email',

        # 每隔2秒执行一次

        # 'schedule': 1.0,

        # 'schedule': crontab(minute="*/1"),

        'schedule': timedelta(seconds=6),

        # 传递参数

        'args': ('张三',)

    },

    # 'add-every-12-seconds': {

    #     'task': 'celery_tasks.task01.send_email',

    #     每年4月11号，8点42分执行

    #     'schedule': crontab(minute=42, hour=8, day_of_month=11, month_of_year=4),

    #     'args': ('张三',)

    # },

} 

# 启动 Beat 程序$ celery beat -A proj<br># Celery Beat进程会读取配置文件的内容，周期性的配置中到期需要执行的任务发送给任务队列

# 之后启动 worker 进程# 启动 Beat 程序$ celery beat -A proj<br># Celery Beat

三、celery执行定时任务的相关教程结束。