26 lines
868 B
Python
26 lines
868 B
Python
|
|
__version__ = 21
|
|
__app__ = 'sensor_node'
|
|
|
|
|
|
DEPENDENCIES = [
|
|
('lib/sht30.py', 'https://raw.githubusercontent.com/rsc1975/micropython-sht30/3b2ec7c46c9d63e37432009002ec1149da341ac7/sht30.py')
|
|
]
|
|
|
|
|
|
async def run(mqtt, name):
|
|
|
|
interval_sub = mqtt.subscribe('home/config/sensor_node/measurement_interval', cls=int)
|
|
location_sub = mqtt.subscribe('config/location', local=True)
|
|
from sht30 import SHT30
|
|
sensor = SHT30()
|
|
temperature, humidity = sensor.measure()
|
|
location = await location_sub.wait_for_value()
|
|
sensor_topic = 'home/sensors/{}/{}'
|
|
mqtt.publish(sensor_topic.format(location, 'temperature'),
|
|
b'{:.2f}'.format(temperature), qos=1, retain=True)
|
|
mqtt.publish(sensor_topic.format(location, 'humidity'),
|
|
b'{}'.format(humidity), qos=1, retain=True)
|
|
|
|
return await interval_sub.wait_for_value()
|