2016-03-24 39 views
1

"MRQ is a distributed task queue for python built on top of mongo, redis and gevent."即使它在文檔的首頁顯示/!\ MRQ is not yet ready for public use. Soon!,它已經看起來非常漂亮了,我仍然使用Getting Started文檔後面的基本功能。使用Python的MRQ庫重複執行的任務

但是,我不明白的是我如何安排重複執行的任務,例如,安排工作每5分鐘運行一次(類似於Celery Beatrq-schedulerAPScheduler)。不幸的是,關於這個特性的文檔is only pointing to the unit tests(雖然說有類似調度器的東西可用),但我無法從測試代碼中找出它的工作原理。

是否有任何可用的示例代碼片段,或者是否有人可以試用這個代碼片段?

回答

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 

我還沒有看到有關如何正確執行此操作的任何明確示例。

相關問題