jerick/homeassistantPi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Changed motion variables, first test

Browse Source
This commit is contained in:
jerick
2022-12-26 03:27:19 -05:00
parent 5baac26ff6
commit fada461518
1 changed files with 10 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
mqtt/motionSensor.py
View File

@@ -11,8 +11,7 @@ from paho.mqtt import client as mqtt_client
name = 'test' name = 'test'
broker = '192.168.0.196' broker = '192.168.0.196'
port = 1883 port = 1883
tempTopic = "home/office/climate/temp" motionTopic = "home/office/motion/status"
humidTopic = "home/office/climate/humid"
username = 'mqtt' username = 'mqtt'
password = 'falrenforbreakfast' password = 'falrenforbreakfast'
@@ -27,7 +26,7 @@ for proc in psutil.process_iter():
#12 is the pin number #12 is the pin number
pir_sensor = 12 pir_sensor = 12
GPIO.setmode(GPIO.BOARD) GPIO.setmode(GPIO.BMC)
GPIO.setup(pir_sensor, GPIO.IN) GPIO.setup(pir_sensor, GPIO.IN)
@@ -50,13 +49,12 @@ def getValues(pir_sensor):
current_state = 0 current_state = 0
try: try:
while True: while True:
time.sleep(0.1) time.sleep(0.1)
current_state = GPIO.input(pir_sensor) current_state = GPIO.input(pir_sensor)
#Condition if motion is detected #Condition if motion is detected
if current_state == 1: if current_state == 1:
print("GPIO pin %s is %s" % (pir_sensor, current_state)) print("GPIO pin %s is %s" % (pir_sensor, current_state))
time.sleep(5) return current_state
except KeyboardInterrupt: except KeyboardInterrupt:
pass pass
finally: finally:
@@ -65,28 +63,18 @@ def getValues(pir_sensor):
def publish(client, temp, humidity): def publish(client, current_state):
#Publish Temp Results #Publish Temp Results
tempMsg = '{{ "temperature": "{}" }}'.format(temp) motionMsg = '{{ "state": "{}" }}'.format(current_state)
#tempMsg = temp #tempMsg = temp
result = client.publish(tempTopic, tempMsg) result = client.publish(motionTopic, motionMsg)
status = result[0] status = result[0]
if status == 0: if status == 0:
#print(f"Send `{tempMsg}` to topic `{tempTopic}`") #print(f"Send `{tempMsg}` to topic `{tempTopic}`")
pass pass
else: else:
print(f"Failed to send message to topic {tempTopic}") print(f"Failed to send message to topic {motionTopic}")
#Publish Humid Results
humidMsg = '{{ "humidity": "{}" }}'.format(humidity)
result = client.publish(humidTopic, humidMsg)
status = result[0]
if status == 0:
#print(f"Send `{humidMsg}` to topic `{humidTopic}`")
pass
else:
print(f"Failed to send message to topic {humidTopic}")
@@ -94,8 +82,9 @@ while True:
#Run functions #Run functions
client = connect_mqtt() # Connect to Broker client = connect_mqtt() # Connect to Broker
client.loop_start() #Start loop client.loop_start() #Start loop
current_value = getValues(pir_sensor) current_state = getValues(pir_sensor)
publish(client, current_value) publish(client, current_state)
client.loop_stop() #Stop loop client.loop_stop() #Stop loop
client.disconnect() # Disconnect client.disconnect() # Disconnect
GPIO.cleanup() GPIO.cleanup()
time.sleep(5)