python - 如何从redis中排队rq中的工作

Question

当它从 mysql 执行时，我必须获取函数和时间，然后将它保存到 redis 中。现在从 redis 中，我必须在规定的时间执行函数。我想使用 rq 作为调度程序，但我无法找到我应该将导入的数据保存到 redis 中的模型。我是 python 和 redis 的新手

Answer 1

如果你安装了 redis，那么有一个文件(对我来说是 ~/lib/python2.7/site-packages/rq/queue.py，它又调用 job.py)清楚地说明了 enqueue 和 enqueue_call 函数:

def enqueue_call(self, func, args=None, kwargs=None,
                 timeout=None, result_ttl=None, description=None,
                 depends_on=None):
    """Creates a job to represent the delayed function call and enqueues it.

    It is much like `.enqueue()`, except that it takes the function's args
    and kwargs as explicit arguments.  Any kwargs passed to this function
    contain options for RQ itself.
    etc...."""

def enqueue(self, f, *args, **kwargs):
    """Creates a job to represent the delayed function call and enqueues it.

    Expects the function to call, along with the arguments and keyword
    arguments.
    etc...."""