69 lines
1.4 KiB
Python
69 lines
1.4 KiB
Python
import RPi.GPIO as gpio
|
|
import time,sys
|
|
from paho.mqtt import client as mqtt_client
|
|
|
|
#mqtt settings
|
|
broker = '192.168.2.2'
|
|
port = 1883
|
|
uname = 'ecyhass'
|
|
pw = 'ecyhass1216'
|
|
topic_sensor = 'garage/door_sensor'
|
|
topic_control = 'garage/door_control'
|
|
client_id = str(210)
|
|
|
|
#GPIO settings
|
|
relay_pin = 15
|
|
sensor_pin = 19
|
|
#gpio setup
|
|
gpio.setmode(gpio.BOARD)
|
|
gpio.setup(relay_pin,gpio.OUT)
|
|
gpio.setup(sensor_pin,gpio.IN,pull_up_down=gpio.PUD_DOWN)
|
|
|
|
def mqtt_connect():
|
|
def on_connect(client, userdata, flags, rc):
|
|
if rc == 0:
|
|
print("Connected to MQTT Broker")
|
|
else:
|
|
print("Failed to Connect MQTT")
|
|
|
|
client = mqtt_client.Client(client_id)
|
|
client.username_pw_set(uname,pw)
|
|
client.on_connect = on_connect
|
|
client.connect(broker,port)
|
|
return client
|
|
|
|
def mqtt_subscribe(client):
|
|
def on_message(client, userdata, msg):
|
|
print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
|
|
|
|
client.subscribe(topic_control)
|
|
client.on_message = on_message
|
|
|
|
def set_relay(value):
|
|
if value==1:
|
|
gpio.output(relay_pin,gpio.HIGH)
|
|
else:
|
|
gpio.output(relay_pin,gpio.LOW)
|
|
|
|
def get_sensor():
|
|
return gpio.input(sensor_pin)
|
|
|
|
def set_from_sensor():
|
|
set_relay(get_sensor())
|
|
|
|
def end():
|
|
gpio.cleanup()
|
|
exit()
|
|
|
|
def main():
|
|
mqtt_subscribe(mqtt_connect())
|
|
while(1):
|
|
continue
|
|
# set_from_sensor()
|
|
# time.sleep(.25)
|
|
|
|
|
|
|
|
if __name__=="__main__":
|
|
main()
|