python调度具有不同时区的作业

Question

我想为具有不同时区的客户列表安排一个python函数每天在某个时间运行。

这基本上就是我想做的：

import schedule
import time
def job(text):
print("Hello " + text)
def add_job(user_tz, time, text):
schedule.every().day.at(time).do(job(text)) 
# the above adds all jobs at local time, I want to use different timezones with these
def run_job():
while(1):
schedule.run_pending()
time.sleep(1)
if __name__=='__main__':
add_job('America/New_York', "12:00", 'New York')
add_job('Europe/London', "12:00", 'London')
run_job()

我使用这个来发布/接收一些使用烧瓶和外部API的东西。

Celery或heroku调度器或重的东西不是我想要的，对于debian(或nix)env来说，轻量级和Python的东西是理想的。我研究了调度器、tzcron和APScheduler，但无法弄清楚如何将它们与时区一起使用。

此外，我还尝试使用crontab，但不知道如何在运行时添加作业，因为我希望能够在运行时使用上述函数添加/删除作业。

我对python有一些经验，但这是我对时区的第一个问题，我对此了解不多，所以如果我错过了什么，或者有其他方法可以做，请随时告诉我。

谢谢！

Answer 1

所描述的问题听起来像是python的调度程序库提供了一个开箱即用的解决方案，不需要用户进一步自定义。调度器库的设计使作业可以在不同的时区进行调度，这与创建调度器的时区以及调度作业的独立时区无关。

披露：我是调度器库的作者之一

为了进行演示，我将文档中的一个示例改编为以下问题：

import datetime as dt
from scheduler import Scheduler
import scheduler.trigger as trigger
# Create a payload callback function
def useful():
print("Very useful function.")
# Instead of setting the timezones yourself you can use the `pytz` library
tz_new_york = dt.timezone(dt.timedelta(hours=-5))
tz_wuppertal = dt.timezone(dt.timedelta(hours=2))
tz_sydney = dt.timezone(dt.timedelta(hours=10))
# can be any valid timezone
schedule = Scheduler(tzinfo=dt.timezone.utc)
# schedule jobs
schedule.daily(dt.time(hour=12, tzinfo=tz_new_york), useful)
schedule.daily(dt.time(hour=12, tzinfo=tz_wuppertal), useful)
schedule.daily(dt.time(hour=12, tzinfo=tz_sydney), useful)
# Show a table overview of your jobs
print(schedule)

max_exec=inf, tzinfo=UTC, priority_function=linear_priority_function, #jobs=3
type     function         due at              tzinfo          due in      attempts weight
-------- ---------------- ------------------- ------------ --------- ------------- ------
DAILY    useful()         2021-07-20 12:00:00 UTC-05:00      1:23:39         0/inf      1
DAILY    useful()         2021-07-21 12:00:00 UTC+10:00     10:23:39         0/inf      1
DAILY    useful()         2021-07-21 12:00:00 UTC+02:00     18:23:39         0/inf      1

使用简单循环执行作业：

import time
while True:
schedule.exec_jobs()
time.sleep(1)  # wait a second

编辑：文档中也提供了异步示例。

Answer 2

箭头库非常适合此功能，而且比标准日期/时间(imo)简单得多。箭头文档。

import arrow
from datetime import datetime
now = datetime.now()
atime = arrow.get(now)
print(now)
print (atime)
eastern = atime.to('US/Eastern')
print (eastern)
print (eastern.datetime)
2017-11-17 09:53:58.700546
2017-11-17T09:53:58.700546+00:00
2017-11-17T04:53:58.700546-05:00
2017-11-17 04:53:58.700546-05:00

我会更改你的"add_job"方法，将我所有的输入日期修改为标准时区(例如utc)。