Articles of websocket

Enviar mensaje WebSocket desde la vista Frask

Estoy tratando de hacer una aplicación Flask que utiliza WebSockets. El ejemplo de Flask-sockets funciona, pero ¿cómo puedo enviar un mensaje desde una vista normal? De manera similar a cómo Flask-SocketIO usa .emit() y .send() -methods. En el siguiente ejemplo (del ejemplo de Flask-Sockets) me gustaría, por ejemplo, poder transmitir un mensaje desde la vista […]

cliente python de signalR

¿Hay un cliente serviseR (ASP .NET CORE 2.0) para python? He encontrado la biblioteca de señales pero es demasiado antigua y no funciona con mi servidor signalR ( Include = “Microsoft.AspNetCore.SignalR” Version = “1.0.0-alpha2-final” ) porque esta biblioteca de python usa ‘/ negociate ‘método, que no se utiliza en las nuevas versiones .

Python, ¿cómo ejecutar comandos en hosts remotos y mostrar resultados en GUI en tiempo real?

Sé que esta es una pregunta realmente abierta, pero soy nuevo en Python y estoy creando una aplicación web única para ofrecer a un equipo no técnico algunas capacidades de autoservicio. Este equipo tiene un montón de tareas repetitivas que transfieren a otro equipo que está simplemente pidiendo ser automatizado, como reiniciar algunos procesos en […]

Python websockets, suscríbete a múltiples canales.

Estoy intentando conectarme a varios canales simultáneamente y recibir mensajes de una API de inserción a través de la biblioteca websocket de python. Teniendo en cuenta el siguiente código a continuación, ¿cómo se conectaría a múltiples canales? este código se obtuvo y se modificó ligeramente desde aquí: https://pypi.python.org/pypi/websocket-client Lo que me confunde es la segunda […]

WebSocket Server envía mensajes periódicamente en Python

Tengo un servidor web de tornado en python: import tornado.httpserver import tornado.websocket import tornado.ioloop from tornado.ioloop import IOLoop import tornado.web import time import threading import sys from datetime import datetime from datetime import timedelta def sample(): print ‘hiiiii’ threading.Timer(10, sample).start() class WSHandler(tornado.websocket.WebSocketHandler): def open(self): print ‘new connection’ def on_message(self, message): self.write_message(message) self.msg(‘hellooooooo’) print message def […]

Pasando datos entre clases en Tweepy y Tornado WebSocket

Tengo dos módulos principales, Tornado WebSocket y Tweepy Streaming, y estoy tratando de que hablen entre ellos. Debajo de on_status en la clase StdOutListener Tweepy (marcada con <– ), me gustaría llamar a la clase WSHandler.on_message Tornado más arriba, con los datos pasados ​​desde on_status . Sin embargo, no puedo hacerlo, ya que recibo mensajes […]

Pruebas de unidad de prueba utilizando Autobahn WebSocket

Estoy tratando de escribir pruebas de unidad para mi aplicación que usa Autobahn. Quiero probar mis controladores, los cuales reciben datos del protocolo, los analizan y reactjsn a ellos. Pero cuando mi prueba llega a un punto en que el protocolo debe desconectarse ( self.sendClose ), se genera un error. exceptions.AttributeError: ‘MyProtocol’ object has no […]

¿Cómo enviar un mensaje desde el proceso hijo a websocket-client en Tornado?

Tengo el servidor Tornado. Recibe mensajes de conexiones websocket. Necesito ejecutar la función del trabajador como un proceso separado y el trabajador debe responder al cliente. La idea principal es trabajar en modo paralelo. Algo como esto def worker(ws,message): input = json.loads(message) t = input[“time”] time.sleep(t) ws.write_message(“Hello, World!”*int(t)) class MainHandler(tornado.web.RequestHandler): def get(self): self.render(‘index.html’) class WebSocket(tornado.websocket.WebSocketHandler): […]

Sobrescribir la clase Autobahn / Twisted WebsocketClientProtocol

Quiero anular mi clase WebSocketClientFactory para permitir que una cola de trabajo se llene con los datos entrantes. Aquí está el código de conexión que estoy tratando factory = WebSocketClientFactory(“ws://localhost:7096”) job_queue = Queue.Queue() factory.protocol = BridgeSocket(job_queue) connectWS(factory) Y aquí está mi clase de socket: class BridgeSocket(WebSocketClientProtocol): def __init__(self,producer_queue): self.producer_queue = producer_queue def sendHello(self): self.sendMessage(“hello”) def […]

Twisted y Websockets: Beyond Echo

En mi curiosidad por los websockets, estoy notando una tendencia: El “hola mundo” del universo websocket, al menos en este momento, parece ser la funcionalidad “eco”. Es decir, la aplicación demostrada suele ser: “Envío algo, recibo algo”. Si bien demuestra adecuadamente que el protocolo es funcional, este ejemplo solo demuestra el mismo tipo de comunicación […]