Articles of websocket

Python WebSocket no funciona

Intenté implementar mi primer ejemplo de websocket pero no puedo hacer que funcione. Yo uso un servidor web python: import threading import socket def start_server(): tick = 0 sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.bind((‘localhost’, 1234)) sock.listen(100) while True: print ‘listening…’ csock, address = sock.accept() tick+=1 print ‘connection!’ handshake(csock, tick) print ‘handshaken’ while True: interact(csock, tick) tick+=1 […]

El código de Websocket funciona en Windows pero no en Linux

Estoy ejecutando el mismo código; Lo siguiente funciona en Windows, pero se ejecutará correctamente en Ubuntu (16.04). import websocket import json class WhatEver(object): def __init__(self): self.ws = websocket.WebSocketApp( ‘wss://beijing.51nebula.com/’, on_message=self.on_ws_message, on_open=self.on_open ) def rin_forever(self): print(“start run forever”) self.ws.run_forever() def on_ws_message(self, ws,message): print (message) self.ws.close() def _send_msg(self, params): call = {“id”: 1, “method”: “call”, “params”: params} […]

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