ptyhon rq队列的使用

本文共有849个字,关键词:

问题: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/
版权声明:本文为作者原创,如需转载须联系作者本人同意,未经作者本人同意不得擅自转载。
添加新评论
暂无评论