安排RQ。
hourglass的Python项目详细描述
hourglass提供了一个按日期排序的队列类Schedule,该类 存储将来某个时间点要运行的作业,以及 守护程序脚本hourglass,将这些作业委托给常规 由rqworker进程处理的队列。
用法
运行包中包含的hourglassdaemon脚本。例子 用法:
import times from datetime import timedelta from rq import use_connection from hourglass import Schedule def test_job(n): return n use_connection() s = Schedule() # schedule a job to be run 3 minutes from now eta = times.now() + timedelta(0, 180) job = s.enqueue(eta, test_job, 5)
hourglass托管作业包括一个附加属性,eta, 这是作为第一个参数传递给^{tt8}的时间$ 和Schedule.enqueue_job。它们还包括另一处房产, queue用于指定在何时将作业分派给哪个队列 eta已过。
Schedule队列和hourglass守护进程在 hood,所以eta传递给调度程序的时间也应该是utc。
更改日志
0.2
rq-0.3.0的兼容性更新
0.1.2
使Schedule.enqueue_job和Schedule.compact成为原子。
0.1.1
python打包的修复。
0.1
初次发布。