-
Notifications
You must be signed in to change notification settings - Fork 18
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
rename to py file. Fix pylint errors
- Loading branch information
Showing
1 changed file
with
34 additions
and
22 deletions.
There are no files selected for viewing
56 changes: 34 additions & 22 deletions
56
examples/mcp9808_average temp+mqtt → examples/mcp9808_average_temp_mqtt.py
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,61 +1,73 @@ | ||
# SPDX-FileCopyrightText: 2021 ladyada for Adafruit Industries | ||
# SPDX-FileCopyrightText: 2022 Taxelas | ||
# SPDX-License-Identifier: MIT | ||
""" | ||
python script to read mcp9808 temperature and publish it in mqtt. | ||
Using discovery topic to create entity in Home Assistant. | ||
""" | ||
|
||
import time | ||
import json | ||
from array import array | ||
import board | ||
import adafruit_mcp9808 | ||
import paho.mqtt.client as mqtt | ||
import numpy as np | ||
import json | ||
import adafruit_mcp9808 | ||
|
||
|
||
i2c = board.I2C() # uses board.SCL and board.SDA | ||
|
||
# To initialise using the default address: | ||
mcp = adafruit_mcp9808.MCP9808(i2c) | ||
|
||
broker_address="Broker IP" | ||
broker_address = "Broker IP" | ||
port = 1883 | ||
user = "mqttuser" | ||
password = "mqttpassword" | ||
client = mqtt.Client("P1") #create new instance | ||
client = mqtt.Client("P1") # create new instance | ||
client.username_pw_set(user, password=password) | ||
client.connect(broker_address, port=port) | ||
client.loop_start() | ||
# To initialise using a specified address: | ||
# Necessary when, for example, connecting A0 to VDD to make address=0x19 | ||
# mcp = adafruit_mcp9808.MCP9808(i2c_bus, address=0x19) | ||
from array import * | ||
from decimal import Decimal | ||
#Create autodiscovery topic for Home assistant | ||
#"ha" is autodiscovery prefix in home assistant | ||
|
||
|
||
# Create autodiscovery topic for Home assistant | ||
# "ha" is autodiscovery prefix in home assistant | ||
send_msg = { | ||
"state_topic": "ha/sensor/sensorLivingroom/state", | ||
"device_class": "temperature", | ||
"unit_of_measurement": "°C", | ||
"value_template": "{{ value_json.temperature }}", | ||
"device": { | ||
"identifiers": [ | ||
"rpisensorgatewayn01" | ||
], | ||
"identifiers": ["rpisensorgatewayn01"], | ||
"manufacturer": "Raspberry", | ||
"model": "RPI 3B", | ||
"name": "Livingroom temperature", | ||
"sw_version": "MCU9808" | ||
"sw_version": "MCU9808", | ||
}, | ||
"name": "Livingroom temperature", | ||
"unique_id": "rpisensorgateway_0x01" | ||
} | ||
client.publish("ha/sensor/sensorLivingroom/config", payload=json.dumps(send_msg), qos=0, retain=True) #publish | ||
temp1m = array('d',[0,0,0,0,0,0,0,0,0] ) #using array to aproximate 10 temperature readings | ||
"unique_id": "rpisensorgateway_0x01", | ||
} | ||
client.publish( | ||
"ha/sensor/sensorLivingroom/config", | ||
payload=json.dumps(send_msg), | ||
qos=0, | ||
retain=True, | ||
) # publish | ||
temp1m = array( | ||
"d", [0, 0, 0, 0, 0, 0, 0, 0, 0] | ||
) # using array to aproximate 10 temperature readings | ||
avgtemp = 0 | ||
while True: | ||
print(len(temp1m)) | ||
for count in range (0,9): | ||
for count in range(0, 9): | ||
temp1m[count] = mcp.temperature | ||
print("Temperature: {} C ".format(mcp.temperature)) | ||
avgtemp = round(np.average(temp1m), 1) | ||
print("avgtemp {} C".format(avgtemp)) | ||
time.sleep(10) | ||
send_msg = { | ||
'temperature': avgtemp | ||
} | ||
client.publish("ha/sensor/sensorLivingroom/state",payload=json.dumps(send_msg)) #publish result in mqtt | ||
send_msg = {"temperature": avgtemp} | ||
client.publish( | ||
"ha/sensor/sensorLivingroom/state", payload=json.dumps(send_msg) | ||
) # publish result in mqtt |