Articles of websocket

¿Cómo llamar a una función asíncrona contenida en una clase?

Sobre la base de esta respuesta , quiero crear un cliente websoket asíncrono en una clase que se importaría de otro archivo: #!/usr/bin/env python3 import sys, json import asyncio from websockets import connect class EchoWebsocket: def __await__(self): # see: https://stackoverflow.com/a/33420721/1113207 return self._async_init().__await__() async def _async_init(self): self._conn = connect(‘wss://ws.binaryws.com/websockets/v3’) self.websocket = await self._conn.__aenter__() return self async […]

Apretón de manos de Python Websocket (RFC 6455)

Estoy tratando de implementar un servidor websoket simple en python, usando el protocolo RFC 6455. Tomé el formato de apretón de manos de aquí y aquí . Estoy usando Chromium 17 y Firefox 11 como clientes, y obtengo este error: Uncaught Error: INVALID_STATE_ERR: DOM Exception 11 Espero ver el hello from server en mi navegador […]

Solución de problemas de Websockets con EC2 en AWS utilizando Django

Estoy usando Django-Channels para intentar obtener funciones en tiempo real como chat / mensajería, notificaciones, etc. En este momento, he logrado que todo funcione bien en mi computadora portátil con la configuración que se describe en la documentación aquí: http: // canales .readthedocs.io / es / latest / . Yo uso un servidor redis local […]

¿Por qué es gevent-websocket síncrono?

Estoy jugando con gevent y websockets. Este es un servidor de eco simple: from gevent.pywsgi import WSGIServer from geventwebsocket.handler import WebSocketHandler from gevent import sleep from datetime import datetime def app(environ, start_response): ws = environ[‘wsgi.websocket’] while True: data = ws.receive() print(‘{} got data “{}”‘.format( datetime.now().strftime(‘%H:%M:%S’), data)) sleep(5) ws.send(data) server = WSGIServer((“”, 10004), app, handler_class=WebSocketHandler) server.serve_forever() […]

Formateo de mensajes para enviar al servidor socket.io node.js desde el cliente de Python

Estoy intentando que un cliente de Python se comunique con un servidor Node.js utilizando Socket.io 0.7, enviando un evento personalizado al servidor. Basado en la referencia Socket.io que he encontrado en GitHub , y en la siguiente biblioteca de WebSocket Python . Aquí está mi código hasta ahora: Servidor de nodos io.sockets.on(‘connection’, function (socket) { […]

Websockets con Tornado: obtenga acceso desde el “exterior” para enviar mensajes a los clientes

Estoy empezando a entrar en WebSockets como una forma de enviar datos de un servidor a clientes conectados. Ya que uso Python para progtwigr cualquier tipo de lógica, miré Tornado hasta ahora. El siguiente fragmento muestra el ejemplo más básico que se puede encontrar en cualquier lugar de la Web: import tornado.httpserver import tornado.websocket import […]

Tornado: ¿Identificar / rastrear conexiones de websockets?

Tengo una prueba básica de websocket Tornado: import tornado.httpserver import tornado.websocket import tornado.ioloop import tornado.web class WSHandler(tornado.websocket.WebSocketHandler): def open(self): print ‘new connection’ self.write_message(“Hello World”) def on_message(self, message): print ‘message received %s’ % message def on_close(self): print ‘connection closed’ application = tornado.web.Application([ (r’/ws’, WSHandler), ]) if __name__ == “__main__”: http_server = tornado.httpserver.HTTPServer(application) http_server.listen(8888) tornado.ioloop.IOLoop.instance().start() Quiero poder […]

Cómo ejecutar funciones fuera del bucle websocket en python (tornado)

Estoy tratando de configurar un pequeño ejemplo de una transmisión pública de Twitter a través de websockets. Este es mi websocket.py, y está funcionando. Lo que me pregunto es: ¿cómo puedo interactuar con el websocket desde ‘fuera’ de la clase WSHandler (es decir, no solo responder cuando se recibe un mensaje de websocket.js)? Digamos que […]

¿Cómo usar autobahn.ws con django?

Necesidad de websockets en mi proyecto. Descubrí la solución de multiplataforma autobahn.ws, pero solo está disponible el tutorial para python puro. ¿Cómo usar autobahn como servidor de chat en el proyecto django?

Cómo crear una aplicación de Python con dos subprocesos cada uno que tiene una aplicación de autollamada

No he encontrado ninguna solución para mi problema. Necesito crear una aplicación de python con dos subprocesos, cada uno de los cuales está conectado a un enrutador WAMP usando la biblioteca autobahn. A continuación escribo el código de mi experimento: wampAddress = ‘ws://172.17.3.139:8181/ws’ wampRealm = ‘s4t’ from threading import Thread from autobahn.twisted.wamp import ApplicationRunner from […]