Tengo un pedazo de código: from twisted.web.client import getPage from twisted.internet import reactor class TestError(Exception): def __init__(self, message): self.message = message def __repr__(self): return ‘TestError’ def gotPage(response): print response reactor.stop() def gotErr(failure): raise TestError(‘This is error’) def newEb(failure): try: failure.raiseException() except TestError as te: print te.message reactor.stop() if __name__ == ‘__main__’: deferred = getPage(‘http://somebadpage.net’, method=’GET’) […]
Estoy trabajando para envolver la aplicación del servidor de Minecraft con un servidor Twisted Python que tiene una API RESTful para obtener la lista de los jugadores conectados actualmente. La aplicación Twisted inicia el servidor de minecraft a través de reactor.spawnProcess () , luego se comunica a través de ProcessTransport , que escribe en stdin. […]
Escribí un servidor TCP usando Python Twisted para enviar / recibir datos binarios de los clientes. Cuando un cliente cierra su aplicación o llama al método abortConnection , normalmente obtengo el evento connectionLost , pero cuando el cliente se desconecta inesperadamente, no obtengo el evento de desconexión, por lo tanto, no puedo eliminar el cliente […]
Logré conectarme a un módem USB y un cliente puede conectarse a través de TCP a mi reactor.listenTCP, los datos recibidos del módem se enviarán de vuelta al cliente. Quiero recibir los datos Recibidos del cliente y enviarlos al módem. Estoy luchando para que esto funcione. ¡Cualquier ayuda será muy apreciada! el código: from twisted.internet […]
Quiero construir un sitio similar a www.omegle.com. ¿Alguien puede sugerirme algunas ideas? Creo que está construido usando un servidor de cometas orbitador torcido.
Estoy tratando de usar Twisted en una especie de progtwig de spidering que administra múltiples conexiones de clientes. Me gustaría mantener un grupo de aproximadamente 5 clientes trabajando al mismo tiempo. La funcionalidad de cada cliente es conectarse a un servidor IRC específico que obtiene de una lista, ingresar a un canal específico y luego […]
ACTUALIZACIÓN: para facilitar la lectura, aquí es cómo agregar una callback antes de que el reactor se apague: reactor.addSystemEventTrigger(‘before’, ‘shutdown’, callable) La pregunta original sigue. Si tengo un cliente conectado a un servidor y se está enfriando en el circuito principal del reactor esperando eventos, cuando presiono CTRL-C, aparece un mensaje “La conexión con el […]
Necesito escribir una aplicación simple que ejecute dos subprocesos: – subproceso 1: se ejecuta en periodos de tiempo, digamos cada 1 minuto – subproceso 2: solo un ‘normal’ mientras que el bucle verdadero hace ‘cosas’ si no fuera por el requisito de correr en un intervalo de tiempo, no habría mirado torcido en absoluto, pero […]
He escrito un bot IRC usando Twisted y ahora he llegado al punto en el que quiero poder recargar dinámicamente la funcionalidad. En mi progtwig principal, from bots.google import GoogleBot y miré cómo usar reload para recargar módulos , pero todavía no puedo averiguar cómo hacer una reimportación dinámica de clases. Entonces, dada una clase […]
Tengo una aplicación que, por conveniencia (estoy reutilizando el código existente) se ha dividido en dos subprocesos diferentes: un hilo corriendo el reactor retorcido otro hilo ejecutando un menú interactivo Una de las cosas que quiero realizar desde el menú interactivo es interactuar con el reactor. Una vez que el usuario da un comando específico, […]