Python: socket Non bloquant ou Asynchronos I/O

Je suis nouveau sur le Python et actuellement à l'écriture d'un python de socket pour être exécuté comme un script qui communique avec un périphérique via TCP/IP (station météo).

L'appareil agit comme le Côté Serveur (d'écoute sur IP:PORT, accepte la connexion, la réception de la demande, le transfert de données).

J'ai seulement besoin d'envoyer un message, recevoir la réponse et ensuite paisiblement et agréablement à l'arrêt et de fermer le socket. 

try:
    comSocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
except socket.error, msg:
    sys.stderr.write("[ERROR] %s\n" % msg[1])
    sys.exit(1)

try:
   comSocket.connect((''))
except socket.error, msg:
   sys.stderr.write("[ERROR] %s\n" % msg[1])
   sys.exit(2)

comSocket.send('\r')
comSocket.recv(128)
comSocket.send('\r')
comSocket.recv(128)
comSocket.send('\r\r')
comSocket.recv(128)

comSocket.send('1I\r\r3I\r\r4I\r\r13I\r\r5I\r\r8I\r\r7I\r\r9I\r\r')

rawData = comSocket.recv(512)

comSocket.shutdown(1)
comSocket.close()

Le problème, je vais avoir est:

Le canal de communication n'est pas fiable, l'appareil est lent. Donc, parfois, le dispositif de réponse avec un message de longueur 0 (juste un accusé de réception), mon code va geler et attendre la réponse à jamais.

Ce morceau de code est constitué de la partie qui implique la PRISE, tout le code sera exécuté sous CRON et le gel n'est pas un comportement souhaitable.

Ma question est:

Quelle serait la meilleure façon Python pour gérer ce comportement, de sorte que le code ne gèle pas et d'attendre éternellement, mais va tenter de passer à la suivante envoyer (ou ces).

Vous devriez regarder les Twisted bibliothèque pour Python. C'est un cadre pour réseau asynchrone ce qui ferait beaucoup plus facile.
Tout en utilisant le Tordu à la bibliothèque de travail, une bibliothèque entière pour un message semble un peu exagéré. Peut-être vous avez besoin d'avoir CRON ouvrir un sous-processus avec votre communication par socket passe dans un thread séparé. De cette façon, vous éviterez le problème de blocage.
depuis que j'ai la même question à celui affiché. Est Tordu n'est pas conçu pour le Serveur? Comment le modifier pour l'utiliser sur le côté client?
ces ne sont pas fondamentalement différents scénarios, les deux sont CLI Python

OriginalL'auteur Tu Hoang | 2011-06-16

  1. 11

    Vous pouvez essayer un délai d'expiration approche, comme Russel code ou vous pouvez utiliser un socket non bloquant, comme le montre le code ci-dessous. Il ne sera jamais bloquer au socket.recv et vous pouvez l'utiliser à l'intérieur d'une boucle pour recommencer autant de fois que vous voulez. De cette façon, votre programme ne sera pas accrocher au délai d'attente. De cette façon, vous pouvez tester si les données sont disponibles et si non, vous pouvez faire d'autres choses et essayer de nouveau plus tard.

    socket.setblocking(0)
while (retry_condition):
    try:
        data = socket.recv(512)
    except socket.error:
        '''no data yet..'''

    OriginalL'auteur Felipe Cruz

  2. 3

    Je le recommande eventlet et fils verts de de cette.

    Torsadée est une bonne bibliothèque, mais un peu raide de la courbe d'apprentissage pour un cas simple d'utilisation.

    Découvrez quelques exemples ici.

    OriginalL'auteur marr75

  3. 0

    Essayer, avant de recevoir, de mettre un timeout sur la socket:

    comSocket.settimeout(5.0)
try:
    rawData = comSocket.recv(512)
except socket.timeout:
    print "No response from server"

    OriginalL'auteur Russell Borogove