Python 中的 RQ 简介

Question

RQ（Redis Queue）是基于 Redis 的消息队列服务框架，任务进入队列后由后台进程处理之，它能轻易集成到系统中，仅支持 Python 语言。RQ 需要 Redis>=2.6.0 版本

安装

RQ 的安装方法非常简单，直接命令：

pip install rq

或者如果你想尝新的话，从 github 安装开发版：

pip install -e git+git@github.com:nvie/rq.git@master#egg=rq

开始

既然是基于 Redis 的服务，那么首先开启 Redis 是必须的，接着把任务放入队列中，任务就是你要处理某件事的过程，它是一个普通的Python函数，通常来说，把任务放在后台进程来处理的都是一些耗时的、对即时性要求比较低的任务，比如：用户注册网站时一般的流程是填写基本信息后会即时返回注册成功的结果，接着才是收到邮件通知要求验证邮件的有效性，其中这个发邮件的任务就可以交给RQ来做。

# my_module.py
def send_mail(email):
    # 模拟发送邮件的过程，整个邮件发送过程需要2秒钟
    time.sleep(2)
    return ‘ok’

然后创建一个 RQ 队列，把任务放入队列

>>> from my_module import send_mail
>>> from redis import Redis
>>> from rq import Queue
>>> q = Queue(connection=Redis())
>>> result = q.enqueue(send_mail, ‘hello@qq.com’)

最后一步就是启动后台进程，后台进程会完成该任务的处理。在项目的目录下执行：

$ rqworker

# 输出
02:25:06 RQ worker started, version 0.4.6
02:25:06
02:25:06 *** Listening on default...
02:25:06 default: my_module.send_mail(‘hello@qq.com’) (77778f9c-2947-4551-aa58-76a77c2c0d8e)
02:25:07 Job OK, result = ok
02:25:07 Result is kept for 500 seconds.

default 是创建队列的时候默认的名字，result＝ok 是任务的返回结果。你看使用 RQ 就这么简单。