问题:python的rq队列使用不成功
解决:没有启动rqworker进程
方法:
下面是python rq使用官方案例
一、安装rq
pip install rq
一、新建文件my_module.py
# -*- coding: UTF-8 -*- import requests
# 需要安装requests,用于抓取网页内容
def count_words_at_url(url):
resp = requests.get(url)
return len(resp.text.split())
二、新建文件rq_main.py
# -*- coding: UTF-8 -*-
import time
from redis import Redis
from rq import Queue
from my_module import count_words_at_url
q = Queue(connection=Redis())
job = q.enqueue(count_words_at_url, 'http://nvie.com')
print(job.result)
time.sleep(2)
print(job.result)
三、运行安装好的rq文件中的rqworker
rqworker
四、运行rq_main.py文件
python rq_main.py
上面程序输出结果是:
None
322 # 这个可能是None
参考:
http://python-rq.org/docs/