Estoy tratando de implementar algo como “tail -f” sobre HTTP con Python. Actualmente, estoy tratando de usar Tornado, pero solo está manejando una conexión a la vez, incluso cuando hago solicitudes asíncronas. import socket import subprocess import tornado.gen as gen import tornado.httpserver import tornado.ioloop import tornado.iostream import tornado.options import tornado.web from tornado.options import define, options […]
Quiero escribir una función personalizada y pasarla a mi plantilla de tornado bien. Al igual que def trimString(data): return data[0:20] luego def trimString(data): return data[0:20] en mi archivo de tornado. Esto debería permitirme recortar cuerdas. es posible? Gracias.
Descubrí cómo usar PIL para obtener las dimensiones de la imagen, pero no el tamaño del archivo en bytes. Necesito saber el tamaño del archivo para decidir si el archivo es demasiado grande para cargarlo en la base de datos.
Estoy intentando usar el nuevo objeto de cola Tornado junto con concurrent.futures para permitir que mi servidor web pase las tareas de uso intensivo de la CPU a otros procesos. Quiero tener acceso al objeto Future que se devuelve desde ProcessPoolExecutor desde el módulo concurrent.futures para que pueda consultar su estado para mostrarlo en el […]
Tengo una aplicación que envía mensajes que deberían transmitirse a todos los clientes conectados actualmente. Digamos que los clientes pueden contar en miles. ¿Cómo logro esta lógica de transmisión sin locking? Código de muestra que creo que bloqueará: clients = [] class Broadcaster(tornado.websocket.WebSocketHandler): def on_message(self, message): for client in clients: self.write_message(message) Cada ejemplo que encontré […]
Intentando instalar Tornado por primera vez (en la instancia de EC2 Linux). yo si pip install tornado y luego intente ejecutar el ejemplo de hello world: http://www.tornadoweb.org/en/stable/#hello-world import tornado.ioloop import tornado.web class MainHandler(tornado.web.RequestHandler): def get(self): self.write(“Hello, world”) application = tornado.web.Application([ (r”/”, MainHandler), ]) if __name__ == “__main__”: application.listen(80) tornado.ioloop.IOLoop.instance().start() Entonces trato de python hello.py pero […]
Hay un método de initialize en la clase tornado.web.RequestHandler , ¿se llama cada vez que hay una solicitud?
Estamos ejecutando un servicio Tornado 3.0 en un sistema operativo RedHat y obtenemos el siguiente error: [E 140102 17:07:37 ioloop:660] Exception in I/O handler for fd 11 Traceback (most recent call last): File “/usr/local/lib/python2.7/dist-packages/tornado/ioloop.py”, line 653, in start self._handlers[fd](fd, events) File “/usr/local/lib/python2.7/dist-packages/tornado/stack_context.py”, line 241, in wrapped callback(*args, **kwargs) File “/usr/local/lib/python2.7/dist-packages/tornado/netutil.py”, line 136, in accept_handler connection, […]
Tengo aplicación de tornado minimalista: import tornado.ioloop import tornado.web class PingHandler(tornado.web.RequestHandler): def get(self): self.write(“pong\n”) if __name__ == “__main__”: application = tornado.web.Application([ (“/ping”, PingHandler), ]) application.listen(8888) tornado.ioloop.IOLoop.instance().start() Tornado sigue reportando solicitudes de error a stderr: WARNING:tornado.access:404 GET / (127.0.0.1) 0.79ms Pregunta: Quiere evitar que registre mensajes de error. ¿Cómo? Tornado versión 3.1; Python 2.6
Estoy usando Tornado. Tengo un montón de manejadores de solicitudes asíncronas. La mayoría de ellos realizan su trabajo de forma asíncrona y luego informan el resultado de ese trabajo al usuario. Pero tengo un manejador cuyo trabajo es simplemente decirle al usuario que su solicitud se procesará en algún momento en el futuro. Termino la […]