我如何安排芹菜团在特定时间运行？

Question

我有以下正常功能，创建芹菜组，并尝试在特定时间运行组中的所有子任务：

def run_sms_task(smstask):

    if smstask:
        phones = []
        for user in smstask.userlist.users.all():
           phones.append(user.profile.phone)

        tasks = []
        for phone in phones:
            tasks.append(send_sms_async.s(phone, smstask.text))
        job = group(tasks)

        result = job.apply_async(eta=smstask.starts_at)
        result.save()
        return result.id

    return None

所有子任务都是在调用此函数时激发的，而不是在定义的“starts\u at”处激发的。怎么了？谢谢！你知道吗

另外，出于测试原因，我编写了一个函数，如果单独启动任务，该函数对我来说很好：

def run_sms_task_test1(smstask):

    if smstask:
        phones = []
        for user in smstask.userlist.users.all():
           phones.append(user.profile.phone)

        tasks = []
        for phone in phones:
            send_sms_async.apply_async([phone, smstask.text], eta=smstask.starts_at)

    return None

Answer 1

可能这是时区问题。你知道吗

尝试使用以下解决方案

from pytz import timezone
from datetime import datetime

london_tz = pytz.timezone('Europe/London')
london_dt = london_tz.localize(datetime.datetime(year, month, day, hour, min))
starts_at = london_dt.astimezone(pytz.UTC)
result = job.apply_async(eta=starts_at)

希望这对你有帮助。你知道吗