用于Dramatiq任务队列的简单调度器

dramatiq任务队列很棒，但缺少调度器。本项目填补了这个空缺。

功能

• 类似Cron的调度。
• 单进程。
• 快速简单的实现。
• 使用SIGALRM节省资源。
• 除了dramatiq的依赖外没有其他依赖。
• CLI与dramatiq保持一致。
• 跳过过时的消息。

安装

periodiq遵循LGPL 3.0+许可证。

$ pip install periodiq

声明周期任务如下

# filename: app.py

import dramatiq
from periodiq import PeriodiqMiddleWare, cron

broker.add_middleware(PeriodiqMiddleWare(skip_delay=30))

@dramatiq.actor(periodic=cron('0 * * * *))
def hourly():
    # Do something each hour…
    ...

然后，使用以下命令运行调度器

$ periodiq -v app
[INFO] Starting Periodiq, a simple scheduler for Dramatiq.
[INFO] Registered periodic actors:
[INFO]
[INFO]     m h dom mon dow          module:actor@queue
[INFO]     ------------------------ ------------------
[INFO]     0 * * * *                app:hourly@default
[INFO]
...

支持

如果您需要帮助或发现了一个错误，请在项目的GitLab上创建一个issue。支持法语和英语。