From b200ec561202a95ad716ffe84fcb6a8fa61bc939 Mon Sep 17 00:00:00 2001 From: Danijel Andjelkovic Date: Thu, 24 Mar 2022 05:04:11 +0100 Subject: Napravio ml mikroservis websocket server. Napravio backend websocket server, i backend socket klijent (za povezivanje sa ml mikroservisom). Napravio frontend websocket klijenta, za povezivanje sa backend-om. --- backend/microservice/ml_socket.py | 25 +++++++++++++++++++++++++ 1 file changed, 25 insertions(+) create mode 100644 backend/microservice/ml_socket.py (limited to 'backend/microservice/ml_socket.py') diff --git a/backend/microservice/ml_socket.py b/backend/microservice/ml_socket.py new file mode 100644 index 00000000..5489b787 --- /dev/null +++ b/backend/microservice/ml_socket.py @@ -0,0 +1,25 @@ +import asyncio +import websockets +import json + +def get_or_create_eventloop(): + try: + return asyncio.get_event_loop() + except RuntimeError as ex: + if "There is no current event loop in thread" in str(ex): + loop = asyncio.new_event_loop() + asyncio.set_event_loop(loop) + return asyncio.get_event_loop() + +# create handler for each connection +async def handler(websocket, path): + #data = json.loads(await websocket.recv()) + #reply = f"Data recieved as: {data}!" + #print(data['test']) + msg = await websocket.recv() + await websocket.send("[" + msg + "]") + +start_server = websockets.serve(handler, "localhost", 5027) + +get_or_create_eventloop().run_until_complete(start_server) +get_or_create_eventloop().run_forever() \ No newline at end of file -- cgit v1.2.3