import asyncio
import websockets

async def consume_ws_latest_records():
    uri = "ws://172.24.0.3:3333/ws_latest_records"

    async with websockets.connect(uri) as websocket:
        while True:
            message = input("Enter a message to send: ")
            await websocket.send(message)

            response = await websocket.recv()
            print(f"Received from server: {response}")

if __name__ == "__main__":
    asyncio.get_event_loop().run_until_complete(consume_ws_latest_records())