Articles of redis

cómo almacenar una imagen en redis usando python / PIL

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 […]

El uso de la agrupación de multiprocesamiento de la tarea de apio genera una excepción

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, […]

Bloquear redis hasta que exista clave

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, […]

redis-py: ¿Cuál es la diferencia entre StrictRedis () y Redis ()?

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?

¿Cuál es la forma correcta de manejar la conexión de Redis en Tornado? (Async – Pub / Sub)

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) […]

Uso de Celery para consultas en tiempo real y sincrónicas de la API con Gevent

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 […]

Frasco: pasando el trabajo del trabajador de fondo (rq, redis)

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 […]

redis – Usando Hashes

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ó […]

¿Cómo puedo usar Tornado y Redis de forma asíncrona?

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’: […]

Python – Cómo verificar si el servidor Redis está disponible

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 […]