socketEngine.py

import asyncio
import websockets
import json
import kafka
import base64


async def hello(websocket, path):
    DproCall=kafka.KafkaProducer()
    
    while True:
        temp = await websocket.recv()
        myJson=json.loads(temp)
        
        print("> "+str(myJson['itration']))
        # ggg=type(myJson['binary'])
        by=bytes(myJson['binary'],encoding='utf-8')
        # f = open("video.webm", "wb")
        # fi=base64.b64decode(myJson['binary'])
        # f.write(fi)
        
        # f.close()
        DproCall.send(topic="viom",value=by)
        DproCall.flush()
        greeting = f"Hello {myJson['itration']}!"

        await websocket.send(greeting)
        # print(f"> {greeting}")


start_server = websockets.serve(hello, 'localhost', 8765)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()
"""bn=[]
for kk in myJson['data'].split(","):
    bn.append(kk)
bi=bytearray(myJson['data'],encoding='utf8')
f = open('static/'+str(myJson['itration'])+'_temp.wav', 'wb')
f.write(bi)
f.close()"""