python - 使用 Python 的 MRQ 库执行重复任务

Question

"MRQ is a distributed task queue for python built on top of mongo, redis and gevent."尽管它声明 /!\MRQ 尚未准备好供公众使用。很快!在文档的首页，它看起来已经非常漂亮了，我成功地使用了入门文档中的基本功能。

但是，我还不明白如何安排重复任务，例如安排作业每 5 分钟运行一次(类似于 Celery Beat 或 rq-scheduler 或 APScheduler )。不幸的是，文档is only pointing to the unit tests关于这个功能(同时指出有类似调度程序的东西可用)，但我无法从测试代码中弄清楚它是如何工作的。

是否有任何带有示例的代码片段，或者是否有人已经实现了尝试？

Answer 1

为了让您开始，

将计划添加到配置文件中，例如 this 。然后使用间隔来设置频率(您也可以使用一天中的时间，但还不知道如何操作)。

使用调度程序 API 重新排队数据不足的任务。

import mrq.scheduler
from mongodb.mongo_client import MongoCLient 

db = MongoClient('localhost',27017)
collection = db.mrq.mrq_scheduled_jobs

task = mrq.scheduler.Schedule(collection)
task.refresh()  ## read mongodb database
task.check()  ## Queues out-of-date tasks

我还没有看到任何关于如何正确执行此操作的明确示例。