Я пытаюсь создать сценарий, который подключается к веб-сокету, что-то записывает в него и затем сохраняет его, не закрывая соединение, потому что в следующую секунду я напишу снова.
Я следовал за документы библиотеки "websockets" для Python, но я не могу понять, как это сделать, потому что я вижу в мониторе сервера веб-сокетов, как этот сценарий подключается и отключается каждую секунду, и это не должно быть , но я не знаю, как это сделать.
Это поведение для async with websockets.connect(f"ws://{host}:{port}") as ws:
, но я не уверен.
Я использую python3 .7 и библиотеку websockets8.1
#!/usr/bin/python3
# -*- coding: UTF-8 -*-
# Libraries used
import time
import asyncio
import websockets
# Function to write in websocket
async def produce(message: str, host: str, port: int) -> None:
async with websockets.connect(f"ws://{host}:{port}") as ws:
await ws.send(message)
print("> {}".format(message))
response = await ws.recv()
print("< {}".format(response))
# Websocket parameters
wsHost='localhost'
wsPort=54682
def main():
iteration = 0
while True:
try:
iteration = iteration + 1
asyncio.run(produce(str(iteration), wsHost, wsPort))
time.sleep(1)
except Exception as e:
print(e)
if __name__ == "__main__":
main()