Python, отправляющий данные в фоновый сервер Websocket - PullRequest
0 голосов
/ 14 сентября 2018

У меня есть расперри пи.Я читаю данные из него.Я отправляю данные через 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()
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...