Как отправлять JSON каждые 3 секунды с помощью websocket [Python-сервер, js-клиент]

Question

У меня есть сервер с Python, который отправляет JSON через websocket, код выглядит следующим образом:

import asyncio
import datetime
import random
import websockets
import json
import threading

stopSignal = 0

def stopTestINT():
    print("test Stop \n")
    stopSignal = 1

async def wsjson(websocket, path):

    while True:

        data = datetime.datetime.now()

        randomINT = random.randint(1, 101)

        sensors_data = {
                'property': {
                    'INT': randomINT,
                    'stop' : stopSignal
                    } 
            }

        timer = threading.Timer(15.0, stopTestINT)  

        if randomINT < 80:
            timer.start()
        else:
            timer.cancel()

        print_json = json.dumps(sensors_data)

        await websocket.send(print_json)
        await asyncio.sleep(3)


start_server = websockets.serve(wsjson, '127.0.0.1', 5678)

asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()

с этим примером кода я отправляю каждые 3 секунды этот json, но на клиенте я получаю (каждые 3секунд) три randomINT.Зачем?

1. И, когда я закрываю соединение (в JS, с помощью ws.close ()) соединение не закрывается, фактически я получаю эту ошибку:

Error in connection handler
Traceback (most recent call last):
  File "C:\*\*\AppData\Local\Programs\Python\Python37-32\lib\site-packages\websockets\server.py", line 169, in handler
    yield from self.ws_handler(self, path)
  File "C:\Users\*\**\websockets py\websjson.py", line 160, in wsjson
    await websocket.send(print_json)
  File "C:\Users\**\Python\Python37-32\lib\site-packages\websockets\protocol.py", line 462, in send
    yield from self.ensure_open()
  File "C:\Users\*\Python\Python37-32\lib\site-packages\websockets\protocol.py", line 646, in ensure_open
    ) from self.transfer_data_exc
websockets.exceptions.ConnectionClosed: WebSocket connection is closed: code = 1005 (no status code [internal]), no reason

2. И таймер не работает, потому что в подсказке я вижу каждые 3 секунды "тестовый останов".

в теории, я хотел, как только придет randomint> 80,затем таймер останавливается и запускается снова, когда находит число <80. </p>

Answer 1

Попробуйте использовать time.sleep(X) вместо таймера в вашем while True выражении.