Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
社区首页 >问答首页 >python工作人员没有读取队列中的作业

python工作人员没有读取队列中的作业
EN

Stack Overflow用户
提问于 2015-02-26 01:30:38
回答 1查看 4.6K关注 0票数 4

在设置python时,我面临一个基本问题-- rqworker似乎无法识别被推送到正在监听的队列中的作业。

所有东西都在virtualenv内部运行

我有以下代码:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
from redis import Redis
from rq import Queue
from rq.registry import FinishedJobRegistry
from videogen import videogen
import time

redis_conn = Redis(port=5001)
videoq = Queue('medium', connection=redis_conn)
fin_registry = FinishedJobRegistry(connection=redis_conn, name='medium')

jobid = 1024
job = videoq.enqueue(videogen, jobid)

while not job.is_finished:
    time.sleep(2)
    print job.result

这里,videogen是一个简单的函数,它立即返回它接收到的整数参数。

在运行rqworker medium并启动应用程序时,没有打印结果。除了以下内容之外,在rqworker中没有任何额外的跟踪:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
14:41:29 RQ worker started, version 0.5.0
14:41:29 
14:41:29 *** Listening on medium...

redis实例可以从我运行rqworker的同一个shell访问,甚至显示更新的键:

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
127.0.0.1:5001> keys *
1) "rq:queues"
2) "rq:queue:medium"
3) "rq:job:9a46f9c5-03e1-4b08-946b-61ad2c3815b1"

那么这里可能缺少什么呢?

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2015-02-26 01:44:25

愚蠢的错误-不得不向rqworker提供redis连接url。

rqworker --url redis://localhost:5001 medium

票数 9
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/28738696

复制
相关文章
python读取excel中的数据
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
全栈程序员站长
2022/11/10
1.8K0
python 读取excel中的数据
http://download.csdn.net/detail/qianminming/2026756#comment
py3study
2020/01/14
2.2K0
Python中的双端队列
前言 本文主要介绍Python中的双端队列deque,具体会介绍: 什么是双端列表? Python列表与双端列表 双端列表的使用 a 什么是双端队列? deque的英文意思是Double-Ended
触摸壹缕阳光
2020/04/26
2K0
通过Python读取elasticsearch中的数据
在前面的分享《通过Python将监控数据由influxdb写入到MySQL》一文中,主要介绍了influxdb-->MySQL。InfluxDB主要存储的由telegraf收集的DB性能数据,此外还有资源、主从、集群等数据。而 Server Log、DB Log(Error Log 和 Slow Log)则是通过filebeat 和 Logstash收集、过滤保存到elasticsearch中。所以,有必要实现通过Python读取elasticsearch中的数据(写入到MySQL)的功能。
东山絮柳仔
2021/05/26
1.7K0
Python 逐行读取socket中的数
网上找到一个简单的用法: socket.makefile().readline()
py3study
2020/01/15
1.5K0
python中读取文件的read、rea
 #读取文件所有内容,返回字符串对象,python默认以文本方式读取文件,遇到结束符读取结束。
py3study
2020/01/20
1.7K0
python读取txt文件中的数组
发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/139543.html原文链接:https://javaforall.cn
全栈程序员站长
2022/08/23
4K0
【搜索引擎】Solr:提高批量索引的性能
几个月前,我致力于提高“完整”索引器的性能。我觉得这种改进足以分享这个故事。完整索引器是 Box 从头开始创建搜索索引的过程,从 hbase 表中读取我们所有的文档并将文档插入到 Solr 索引中。
架构师研究会
2022/05/30
6570
【搜索引擎】Solr:提高批量索引的性能
Python中的队列结构及其用法
Python标准库queue提供了LILO队列类Queue、LIFO队列类LifoQueue、优先级队列类PriorityQueue,标准库collections提供了双端队列。 >>> from queue import Queue #LILO队列 >>> q = Queue() #创建队列对象 >>> q.put(0) #在队列尾部插入元素 >>> q.put(1) >>> q.put(2) >>> print(q.queue) #查看队列中所有元素 deque([0, 1, 2]) >>>
Python小屋屋主
2018/04/16
1.1K0
数据结构_栈和队列_作业
在逻辑上都是线性结构,栈和队列本质就是特殊的线性表,都可以用链表或者顺序表进行存储
用户10551528
2023/05/09
1980
数据结构_栈和队列_作业
python读取txt文件中的json数据
txt文本文件能存储各式各样数据,结构化的二维表、半结构化的json,非结构化的纯文本。 存储在excel、csv文件中的二维表,都是可以直接存储在txt文件中的。
全栈程序员站长
2022/08/30
7.2K0
python读取txt文件中的json数据
python作业
    if (name1 in name and passwd1 in passwd):
py3study
2020/01/10
8330
Python读取结果写入Excel中
列表嵌套字典。Excel中的url,test_method,data,title等都是一个键,url,test_method,data,title下面的数据就是要取的值,也就是Key和value的形式。
清菡
2020/12/02
2.3K0
Python读取结果写入Excel中
[日常] 读取队列并循环发信的脚本
<?php /** * 发送群发邮件脚本 * 查询队列内列表,循环调用smtp发送邮件 */ $emlDir="/mnt/entmail/mass_mail/"; //读取redis数据 $so
唯一Chat
2019/09/10
5040
【Python基础】Python中读取图片的6种方式
Python进行图片处理,第一步就是读取图片,这里给大家整理了6种图片的读取方式,并将读取的图片装换成numpy.ndarray()格式。首先需要准备一张照片,假如你有女朋友的话,可以用女朋友的,没有的话,那还学啥Python,赶紧找对象去吧!
黄博的机器学习圈子
2020/11/09
7.6K0
【Python基础】Python中读取图片的6种方式
Python中的堆排序与优先队列
对数据进行排序是一个很常见的需求,但有时候我们并不需要对完整的数据进行排序,只需要排前几的数据,也就是经典的 Top-K 问题。
子润先生
2021/06/18
4640
Python中的堆排序与优先队列
对数据进行排序是一个很常见的需求,但有时候我们并不需要对完整的数据进行排序,只需要排前几的数据,也就是经典的 Top-K 问题。
杜逸先
2021/06/09
1.3K0
Python读取邮箱中的邮件,含文本,附
#-*- encoding: utf-8 -*- import sys import locale import poplib from email import parser import email import string # 确定运行环境的encoding __g_codeset = sys.getdefaultencoding() if "ascii"==__g_codeset: __g_codeset = locale.getdefaultlocale()[1] # def obj
py3study
2020/01/08
2.3K0
点击加载更多

相似问题

Resque:作业必须放在队列中。不能为类工作人员推断队列。

10

python作业队列实现

91

使用Java、spring、redis的作业队列和工作人员

10

调度python清除作业队列

18

python电报bot中的作业队列问题

13
添加站长 进交流群

领取专属 10元无门槛券

AI混元助手 在线答疑

扫码加入开发者社群
关注 腾讯云开发者公众号

洞察 腾讯核心技术

剖析业界实践案例

扫码关注腾讯云开发者公众号
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
查看详情【社区公告】 技术创作特训营有奖征文