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将跳过一个运行。在

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java Play Framework 2.1中的简单搜索?   java:Springbeans的真正工作原理   java不能从字符串中提取数字   不同管道中的java共享ExecutionHandler   在Java中,如何为扩展comparator的类实现多个comparator方法?   通用混沌Java   java问题:从自定义类获取要添加到驱动程序类的形状   java如何利用HikariCP和Hibernate?   eclipse如何执行Java应用程序?   用户界面Java Swing:如何将JLabel的文本绑定到JTable选定行中的列?   java替换JPanel元素而不添加到面板的末尾?   java Sets根据action命令在按钮组中选择了特定的jradiobutton   在java中如何将从控制台添加的字符串中的元素添加到列表中   处理未在浏览器上运行的Java签名小程序   java如何在我的安卓应用程序中单击任意按钮时禁用音频音调?   编码如何在Java中将十六进制转换为utf8编码的字符串   java JSF Spring安全集成问题   java如何更正Oracle for Windows中的字符?   java Spark结构化流媒体:当前批次落后   java Hibernate根据最匹配的条件排序结果