如何在特定时间启动 Tornado 周期性回调？

Question

目前在我的 Tornado 应用程序中，我PeriodicCallback每隔一小时定期调用一次回调。像这样：

import tornado.ioloop
from tornado.ioloop import PeriodicCallback

if __name__ == "__main__":
    tornado.options.parse_command_line()
    app = tornado.web.Application(
      handlers=urls,
      template_path=os.path.join(os.path.dirname(__file__), "templates"),
      static_path=os.path.join(os.path.dirname(__file__), "static"),
      debug=True
      )
    http_server = tornado.httpserver.HTTPServer(app)
    http_server.listen(options.port)

    # Here i have option to specify interval, but how to specify when to start?
    daily_alerts = PeriodicCallback(lambda: send_email.daily_alert(), 3600000)
    daily_alerts.start()
    tornado.ioloop.IOLoop.instance().start()

在这里，我可以选择设置间隔时间 ( 3600000)，但如何指定此定期回调应何时开始？

Answer 1

如果你想精确控制回调的调度时间，最好IOLoop.add_timeout直接使用而不是PeriodicCallback.

def schedule_next_email():
    tomorrow = datetime.date.today() + datetime.timedelta(days=1)
    midnight = datetime.combine(tomorrow, datetime.time.min)
    def wrapper():
        send_email.daily_alert()
        schedule_next_email()
    IOLoop.current().add_timeout(midnight, wrapper)

schedule_next_email()  # call at startup to schedule first call

每次重新计算间隔有助于您每天在同一时间发送，即使夏令时发生变化并且天可以有 23 或 25 小时。