py_redis_post_client.py

class Client():
        def __init__(self, evt_loop):
            self.event_loop = evt_loop
            self.reader = None
            self.writer = None

        async def execute(self, cmd):
            if self.reader == None:
                if cmd.startswith('.connect'):
                    cmd = cmd.replace('.connect', '').strip()
                    parts = cmd.split(':')
                    (r, w) = await asyncio.open_connection(parts[0], parts[1], loop=self.event_loop)
                    self.reader = r
                    self.writer = w
                else:
                    return 'Please connect with <.connect ip:port>'
            else:
                cmd = cmd.split(' ')
                self.writer.write(encode(cmd).encode())
                data = await self.reader.read(1024)
                return decode(data.decode())

        def close(self):
            if self.writer != None:
                self.writer.close()