Articles of tornado

En Tornado, ¿cómo hacer la lectura / escritura de archivos sin locking?

He estado usando Tornado por un tiempo y me he encontrado con problemas de tiempo lento (que pregunté en esta pregunta ). Un posible problema que fue señalado por otro usuario fue que estaba usando el método regular open(“…” , ‘w’) para escribir en los archivos de mi co-rutina y que esto podría ser un […]

Ejecutar una aplicación Pyramid WSGI bajo tornado

Pyramid utiliza su propio servidor web de Waitress para fines de desarrollo, pero quiero servir mi aplicación WSGI bajo Tornado. Creo que debería configurarlo usando los archivos psini .ini, pero no puedo hacer que funcione

¿Cómo mejorar el rendimiento de la combinación de gevent y tornado?

Estoy tratando de usar gevent como servidor wsgi, y uso la aplicación WSGIA de tornado para procesar las solicitudes. Aquí está el código #!/usr/bin/env python # coding=utf-8 import gevent from gevent import monkey monkey.patch_all(thread=False) from gevent.pywsgi import WSGIServer from tornado.wsgi import WSGIApplication import tornado.web import tornado.wsgi import requests class MainHandler(tornado.web.RequestHandler): def get(self): requests.get(‘http://google.com’) self.write(‘hello’) handlers […]

Python: ¿Cómo combinar una encuesta de proceso y un servidor WebSocket sin locking?

Tengo una idea. Escriba un RPC basado en WebSocket que procesaría los mensajes de acuerdo con el siguiente escenario. El cliente se conecta a un servidor WS (web socket) El cliente envía un mensaje al servidor WS El servidor WS coloca el mensaje en la cola entrante (puede ser una cola de multiprocesamiento. Cita o […]

Ejecutando código de locking en Tornado

Tengo una aplicación de tornado y quiero usar una biblioteca de locking para lograr algo. En los casos en los que no es posible volver a escribir la biblioteca de forma asíncrona, ¿cuál es la forma de ejecutarlo en un tornado? Por ejemplo, me gustaría poder poner un decorador @asynchronous en un controlador de solicitudes, […]

SQLAlchemy + Tornado: ¿Cómo crear un scopefunc para ScopedSession de SQLAlchemy?

Al usar tornado, quiero crear un poco de magia de middleware que asegure que mis sesiones de SQLAlchemy se cierren / limpien adecuadamente para que los objetos no se compartan de una solicitud a la siguiente. El truco es que, dado que algunos de mis controladores de tornado son asíncronos, no puedo compartir una sesión […]

Python SyntaxError: (“‘return’ con argumento dentro del generador”,)

Tengo esta función en mi progtwig de Python: @tornado.gen.engine def check_status_changes(netid, sensid): como_url = “”.join([‘http://131.114.52:44444/ztc?netid=’, str(netid), ‘&sensid=’, str(sensid), ‘&start=-5s&end=-1s’]) http_client = AsyncHTTPClient() response = yield tornado.gen.Task(http_client.fetch, como_url) if response.error: self.error(“Error while retrieving the status”) self.finish() return error for line in response.body.split(“\n”): if line != “”: #net = int(line.split(” “)[1]) #sens = int(line.split(” “)[2]) #stype = […]

Pitón. Tornado. Cliente xmlrpc sin locking

Básicamente podemos llamar a los manejadores xmlrpc de la siguiente manera: import xmlrpclib s = xmlrpclib.ServerProxy(‘http://remote_host/rpc/’) print s.system.listmethods() En tornado podemos integrarlo así: import xmlrpclib import tornado.web s = xmlrpclib.ServerProxy(‘http://remote_host/rpc/’) class MyHandler(tornado.web.RequestHandler): def get(self): result = s.system.listmethods() Tengo las siguientes, un poco novato, preguntas: ¿El result = s.system.listmethods() bloqueará el tornado? ¿Hay algún cliente xmlrpc […]

Prueba de unidad de tornado con sockets web: ¿qué pasa con el contexto de stack?

He estado usando el servidor de tornado por un tiempo y tengo que decir que me gusta. Tengo un servidor de tornado (que se ejecuta en python3.2) que maneja solicitudes de http y socket web. Lo que quiero hacer es escribir algunas pruebas unitarias (que usan sockets web) con ws2py (que implementa un cliente ws […]

Tornado websocket handler, self.close () está cerrando la conexión sin activar el método on_close ()

soy nuevo en (python, stackoverflow, tornado), así que por favor, sea paciente :). Corrígeme. Estoy trabajando con tornado en una aplicación en tiempo real. Cuando llamo a self.close () dentro de la clase de manejador Websocket, el método on_close no se activa, por esta vez hice un pequeño envoltorio, solucionando el problema y (por ejemplo) […]