Estoy usando python y el módulo de imagen (PIL) para procesar las imágenes. Quiero almacenar el flujo de bits sin procesar del objeto de imagen para volver a hacer que otros puedan leer directamente las imágenes de redis utilizando nginx y httpredis. por lo tanto, mi pregunta es cómo obtener los bits en bruto de […]
PARA AQUELLOS QUE LEEN ESTO: he decidido utilizar RQ, que no falla cuando se ejecuta el código que utiliza el módulo de multiprocesamiento. Te sugiero que uses eso. Estoy tratando de usar un grupo de multiprocesamiento dentro de una tarea de apio usando Python 3 y redis como intermediario (ejecutándolo en una Mac). Sin embargo, […]
Soy nuevo en Redis y me preguntaba si hay una manera de poder await get un valor por clave hasta que exista la clave. Código mínimo: async def handler(): data = await self._fetch(key) async def _fetch(key): return self.redis_connection.get(key) Como usted sabe, si tal key no existe, no return None . Pero como en mi proyecto, […]
Quiero usar redis-py para almacenar algunos datos, pero no puedo encontrar una explicación adecuada de la diferencia entre redis.StrictRedis() y redis.Redis() . ¿Son equivalentes? Además, no puedo encontrar ninguna documentación clara sobre los redis.StrictRedis() de redis.StrictRedis() en Redis Python Docs . ¿Alguna idea?
Estoy usando Redis junto con mi aplicación Tornado con el cliente de Asyc Brukva, cuando observé las aplicaciones de muestra en el sitio de Brukva, están realizando una nueva conexión en el método ” init ” en websocket class MessagesCatcher(tornado.websocket.WebSocketHandler): def __init__(self, *args, **kwargs): super(MessagesCatcher, self).__init__(*args, **kwargs) self.client = brukva.Client() self.client.connect() self.client.subscribe(‘test_channel’) def open(self): self.client.listen(self.on_message) […]
Estoy trabajando en una aplicación web que recibirá una solicitud de un usuario y tendrá que acceder a una serie de API externas para componer la respuesta a esa solicitud. Esto se puede hacer directamente desde el hilo principal de la web usando algo como gevent para expandir la solicitud. Alternativamente, estaba pensando, podría poner […]
Quiero hacer una cosa muy simple: lanzar un trabajador a algo y luego devolver la respuesta al usuario. Estoy tratando de hacerlo usando una combinación de Flask y RQ. import os from flask import Flask, session from somewhere import do_something from rq import Queue from worker import conn app = Flask(__name__) app.debug = True app.secret_key […]
Estoy implementando un flujo social y un sistema de notificación para mi aplicación web usando redis. Soy nuevo en redis y tengo algunas dudas sobre los hashes y su eficiencia. He leído esta increíble publicación de Instagram y planeo implementar su solución similar para un almacenamiento mínimo. Como se menciona en su blog, les gustó […]
Estoy tratando de encontrar cómo puedo usar Redis y Tornado de forma asíncrona. Encontré el tornado–redis pero necesito más que simplemente agregar un yield en el código. Tengo el siguiente código: import redis import tornado.web class WaiterHandler(tornado.web.RequestHandler): @tornado.web.asynchronous def get(self): client = redis.StrictRedis(port=6279) pubsub = client.pubsub() pubsub.subscribe(‘test_channel’) for item in pubsub.listen(): if item[‘type’] == ‘message’: […]
Estoy desarrollando un Servicio Python (Clase) para acceder a Redis Server. Quiero saber cómo verificar si Redis Server se está ejecutando o no. Y también si de alguna manera no puedo conectarme a él. Aquí hay una parte de mi código. import redis rs = redis.Redis(“localhost”) print rs Imprime lo siguiente incluso si mi Redis […]