ko namecron扩展名
nameko-cron的Python项目详细描述
Nameko Cron公司
NamekoCron
入口点基于cron表达式激发。它不支持群集,并且
将在所有服务实例上激发。cron调度基于croniter。在
使用
fromnameko_cronimportcronclassService:name="service"@cron('*/5 * * * *')defping(self):# executes every 5 minutesprint("pong")
还提供时区感知cron计划
^{pr2}$默认情况下,如果某个工作进程比下一个计划的运行时间长,则该工作进程将一直等到
任务在立即启动新工作线程之前已完成。这种行为是可以控制的
通过concurrency
关键字参数。在
ConcurrencyPolicy.WAIT
是默认行为。在
ConcurrencyPolicy.ALLOW
将生成一个worker,而不管现有worker是否仍在运行。在
如果上一个工作进程使下一个计划的运行失败,ConcurrencyPolicy.SKIP
将跳过一个运行。在
- 项目
标签: