Articles of Autobahn

¿Leyendo mensajes en Poloniex Trollbox con Python autbahn u otro módulo de socket?

Poloniex no devuelve todos los mensajes a mi socket. Leí los mensajes con el siguiente código y, a veces, recibo números de mensajes continuos, pero a veces faltan 10 mensajes: from autobahn.asyncio.wamp import ApplicationSession from autobahn.asyncio.wamp import ApplicationRunner from asyncio import coroutine class PoloniexComponent(ApplicationSession): def onConnect(self): self.join(self.config.realm) @coroutine def onJoin(self, details): def onTrollbox(*args): print(“type: “, […]

Cómo leer datos de forma asíncrona a través de modbus / TCP y enviarlos a la web

Necesito recibir datos del dispositivo conectado a través de Ethernet (modbus / TCP) y enviarlos a la página web (tal vez utilizando sockets web). No puedo encontrar buenos ejemplos. Ahora puedo conectarme con el controlador e imprimir valores utilizando ModbusClientProtocol.read_input_registers() pero tuve que crear mi propia clase de protocolo y fábrica. Estoy usando autobahn, twisted, […]

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

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

¿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 […]

Python – Ejecutando el servidor websocket de Autobahn | Python asyncio en un subproceso o subproceso separado

Tengo un progtwig GUI basado en tkinter que se ejecuta en Python 3.4.1. Tengo varios subprocesos que se ejecutan en el progtwig para obtener datos JSON de varias direcciones URL. Estoy deseando agregar algunas funciones de WebSocket para poder permitir que el progtwig actúe como un servidor y permitir que varios clientes se conecten a […]

SendMessage desde afuera en autobahn corriendo en un hilo separado

Quiero llamar sendMessage método sendMessage desde fuera de la clase MyServerProtocol y enviar un mensaje a los clientes conectados. Yo uso threading para hacer esto. Cuando uso este código: from autobahn.twisted.websocket import WebSocketServerProtocol, WebSocketServerFactory from twisted.internet import reactor import threading class MyServerProtocol(WebSocketServerProtocol): def onConnect(self, request): print(“Client connecting: {0}”.format(request.peer)) def onOpen(self): print(“WebSocket connection open.”) def onMessage(self, […]