У меня есть расперри пи.Я читаю данные из него.Я отправляю данные через mqtt на удаленный сервер и отправляю данные клиенту.Я хочу, чтобы данные всегда отправлялись на хост mqtt, теперь данные отправляются, только если я обновляю данные из веб-сокета?
import paho.mqtt.client as mqtt
import configparser
import asyncio
import websockets
import os
import time
from random import uniform, normalvariate
broker_address="mqtthost.org"
client = mqtt.Client("P1") #create new instance
client.connect(broker_address) #connect to brok
async def send(websocket, path):
while True:
val = round(uniform(0,10), 2)
await client.publish("sensor/temperature", val)#publish
await websocket.send(val)
#await asyncio.sleep(1)
start_server = websockets.serve(send, '127.0.0.1', 5678)
asyncio.get_event_loop().run_until_complete(start_server)
asyncio.get_event_loop().run_forever()