目前在我的 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
),但是我如何指定这个定期回调应该何时开始?
如果你想精确控制回调的安排时间,最好使用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 小时。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)