Path: csiph.com!fu-berlin.de!uni-berlin.de!not-for-mail
From: Pavlos Parissis <pavlos.parissis@gmail.com>
Newsgroups: comp.lang.python
Subject: asyncio for UNIX socket
Date: Thu, 17 Dec 2015 02:16:11 +0100
Lines: 72
Message-ID: <mailman.27.1450314981.30845.python-list@python.org>
Mime-Version: 1.0
Content-Type: multipart/signed; micalg=pgp-sha256; protocol="application/pgp-signature"; boundary="HjL0aPeCdOC7AfLSAbUbUEn7DtHJuCiKi"
User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:31.0) Gecko/20100101 Icedove/31.8.0
Precedence: list
Xref: csiph.com comp.lang.python:100546

This is an OpenPGP/MIME signed message (RFC 4880 and 3156)
--HjL0aPeCdOC7AfLSAbUbUEn7DtHJuCiKi
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable

Hi,
I am trying to write UNIX socket client which sends 1 cmd
and saves the received data to a file.
Based on what I found on documentation I came up with::

import asyncio
class UnixProtocol(asyncio.Protocol):
    def __init__(self, loop):
        self.cmd =3D 'show stat\n'
        self.loop =3D loop
        self.data =3D []

    def connection_made(self, transport):
        transport.write(self.cmd.encode())
        print('Data sent: {!r}'.format(self.message))

    def data_received(self, data):
        print('Data received: {!r}'.format(data))
        self.data.append(data.decode())

    def connection_lost(self, exc):
        print('The server closed the connection')
        print('Stop the event loop')
        if self.data:
            with open('/tmp/somedata', 'w') as fp:
                fp.writelines(self.data)
        self.loop.stop()

loop =3D asyncio.get_event_loop()
s_file =3D '/run/haproxy/admin1.sock'
coro =3D loop.create_unix_connection(lambda: UnixProtocol(loop), s_file)
loop.run_until_complete(coro)
loop.run_forever()
loop.close()

I am not sure if the above is the proper way to do the job.
Am I doing the right thing to write the data to the file when peer
closes the connection?

Thanks,
Pavlos


--HjL0aPeCdOC7AfLSAbUbUEn7DtHJuCiKi
Content-Type: application/pgp-signature; name="signature.asc"
Content-Description: OpenPGP digital signature
Content-Disposition: attachment; filename="signature.asc"

-----BEGIN PGP SIGNATURE-----
Version: GnuPG v2

iQIcBAEBCAAGBQJWcgzbAAoJEIP8ktofcXa5PxEP/jPxl2b8FzyMDkJfO9ljxUrp
QDLU3FrtEVYpIZqJSyay+BEgnyMGoB7yxIhUOj74jIQ3jkKGsw2VY05w4+ar6a41
5KsLTriMrp6w6I20xykZ40ReecsTqhyMTfquviDhlGncoT8RDKhyIUcU6C9bIc0k
KJOMN+mB3EEcjk/yTfFizhrPHMywSJcWmfAPqhNzu20idVDVEldh8sQeAYJnD2w8
wNBLt0/bd97b8AhLOtCGlI2gJJDnQ3fLK1ie7MApaCGymWoUQWo4dyhh89GuHmJR
ansVIfcC+Kb8jLipc0B9G9XQYcyX4EW2C2z0xvgLuDNqUaLK8ju/RM/K4qDA5yO5
35Jfhq6g9mPVvp3lKsMO3e9azkxq7aqqIgjgMmde2dvfZ+WJIRTAPrgZ7M99EQNy
/hflc/jawU8aEmARp4zp2VKWWMA9XCdNCIGzzOG5cSyWAQxG/J5esDG/2XO5atc+
MLEXCmHP4vRt6vCiWV/Ric6kkAdsz+ljVQGRF431d7qhHxaN6Lmgm+W2i9wzjQ1K
RardvkjWL3NOkEyLb4a+bUvboqrkf8jADO66taJNNTlNwEJhiOMynyKjJS33O9G8
Y6TdVHvZPUxGIVqyahM7nKz1bu31pMc91ooopQh8AGVKBZcr6/zsLdrmLT4yv3pf
iRu/nOy8CwkjfSTRkn/T
=fpZz
-----END PGP SIGNATURE-----

--HjL0aPeCdOC7AfLSAbUbUEn7DtHJuCiKi--