在项目目录例子的基础上进行修改一下

from Celery_task.task_1 import func1from Celery_task.task_2 import func2# func1.delay()# func2.delay()# 定时任务我们不在使用delay这个方法了,delay是立即交给task 去执行# 现在我们使用apply_async定时执行#首先我们要先给task一个执行任务的时间import datetime,time# 获取当前时间 此时间为东八区时间ctime = time.time()# 将当前的东八区时间改为 UTC时间 注意这里一定是UTC时间,没有其他说法utc_time = datetime.datetime.utcfromtimestamp(ctime)# 为当前时间增加 10 秒add_time = datetime.timedelta(seconds=10)action_time = utc_time + add_time# action_time 就是当前时间未来10秒之后的时间#现在我们使用apply_async定时执行res = one.apply_async(args=(10,10),eta=action_time)print(res.id)#这样原本延迟5秒执行的One函数现在就要在10秒钟以后执行了