Nameko cron 扩展
项目描述
Nameko Cron
NamekoCron入口点基于 cron 表达式触发。它不是集群感知的，将在所有服务实例上触发。cron 计划基于croniter。
用法
from nameko_cron import cron
class Service:
name ="service"
@cron('*/5 * * * *')
def ping(self):
# executes every 5 minutes
print("pong")
时区感知 cron 计划也可用
from nameko_cron import cron
class Service:
name ="service"
@cron('0 12 * * *', tz='America/Chicago')
def ping(self):
# executes every day at noon America/Chicago time
print("pong")
默认情况下，如果工作人员的运行时间比下一次计划运行时间长，工作人员将等到任务完成后再立即启动新工作人员。可以通过concurrency关键字参数控制此行为。
ConcurrencyPolicy.WAIT是默认行为。
ConcurrencyPolicy.ALLOW无论现有的工人是否仍在运行，都会产生一个工人。
ConcurrencyPolicy.SKIP如果前一个工作人员错过了下一次计划的运行，则将跳过运行。
下载文件
下载适用于您平台的文件。如果您不确定要选择哪个，请了解有关安装包的更多信息。
源分布
nameko-cron-0.1.0.tar.gz
（3.4 kB
查看哈希）
内置分布
nameko_cron-0.1.0-py3-none-any.whl
（4.3 kB
查看哈希）
关
nameko_cron -0.1.0-py3-none-any.whl 的哈希值
| 算法 | 哈希摘要 | |
|---|---|---|
| SHA256 | 19f9f1590178c52bc29990c0751f55e8ecba674ed8549dc08b7f32fad1cc6a5f |
|
| MD5 | 2dec3fc9cab5971c89039c28ab7b61c1 |
|
| 布莱克2-256 | 00ab122017cceed8430d4b7d284d58cd8c60639ce7c71124a6f8f57865e5b6fc |