http://192.168.2.200:8123/
มีไว้สำหรับปิด หรือ เปิด Air Manual เมื่อ MN-Server ไม่ทำงาน หรือสั่งงานไม่ได้
1. ROOM_A_ON_OFF (ไว้ปิดเปิด Air ตึกหน้า เปิดจะเปิดทั้งสองตัว เพราะมี PI เครื่องเดียว สั่ง GPI อันเดียว)
- nano /home/homeassistant/.homeassistant/configuration.yaml
- - platform: mqtt
- name: "ROOM_A_ON_OFF"
- state_topic: "hass/state/ROOM_A_ON_OFF"
- command_topic: "hass/cmd/ROOM_A_ON_OFF"
- payload_on: "ON"
- payload_of: "OFF"
- retain: true
ใช้ Service ที่เครื่อง Raspberry PI ในการรับส่ง mqtt ชื่อ ROOM_A_ON_OFF
Code ที่เครื่อง PI
- nano /home/pi/mqttAir.py
- #!/usr/bin/python
- # -*- coding: utf-8 -*-
- # Copyright (c) 2010-2013 Roger Light <roger@atchoo.org>
- #
- # All rights reserved. This program and the accompanying materials
- # are made available under the terms of the Eclipse Distribution License v1.0
- # which accompanies this distribution.
- #
- # The Eclipse Distribution License is available at
- # http://www.eclipse.org/org/documents/edl-v10.php.
- #
- # Contributors:
- # Roger Light - initial implementation
- # Copyright (c) 2010,2011 Roger Light <roger@atchoo.org>
- # All rights reserved.
- # This shows a simple example of an MQTT subscriber.
- #import context # Ensures paho is in PYTHONPATH
- import paho.mqtt.client as mqtt
- ### PI ###
- import RPi.GPIO as GPIO #Add the GPIO library to a Python sketch
- import time #Add the time library to a Python sketch
- GPIO.setwarnings(False)
- GPIO.setmode(GPIO.BOARD) #Setup GPIO using Board numbering
- GPIO.setup(16, GPIO.OUT)
- ### Piface ###
- import pifacedigitalio
- pf = pifacedigitalio.PiFaceDigital()
- def on_connect(mqttc, obj, flags, rc):
- print("rc: " + str(rc))
- def on_message(mqttc, obj, msg):
- print(msg.topic + " " + str(msg.qos) + " " + str(msg.payload))
- mqttc.publish("hass/state/ROOM_A_ON_OFF", str(msg.payload), 0, True)
- ## ON OFF ##
- if str(msg.payload) == "ON":
- #GPIO.output(16,GPIO.HIGH)
- pf.relays[1].turn_on()
- pf.relays[0].turn_on()
- else:
- pf.relays[1].turn_off()
- pf.relays[0].turn_off()
- #GPIO.output(16,GPIO.LOW)
- def on_publish(mqttc, obj, mid):
- print("mid: " + str(mid))
- def on_subscribe(mqttc, obj, mid, granted_qos):
- print("Subscribed: " + str(mid) + " " + str(granted_qos))
- def on_log(mqttc, obj, level, string):
- print(string)
- # If you want to use a specific client id, use
- # mqttc = mqtt.Client("client-id")
- # but note that the client id must be unique on the broker. Leaving the client
- # id parameter empty will generate a random id for you.
- mqttc = mqtt.Client()
- mqttc.on_message = on_message
- mqttc.on_connect = on_connect
- mqttc.on_publish = on_publish
- mqttc.on_subscribe = on_subscribe
- # Uncomment to enable debug messages
- # mqttc.on_log = on_log
- mqttc.connect("192.168.2.200", 1883, 60)
- mqttc.subscribe("hass/cmd/ROOM_A_ON_OFF", 0)
- mqttc.loop_forever()
Run เป็น Service
https://intranet.sci.com/blog.php?u=281&b=1583
Service
- sudo python /home/pi/mqttAir.py
ไว้รับคำสั่ง mqtt และสั่งเปิด Air ตาม Code
****** หมายเหตุ บางครั้งสั่งแล้วไม่ปิดไม่เปิด Service อาจจะค้าง ต้อง Restart Service ใหม่ หรือ Reboot เครื่อง PI ใหม่ *******
2. ROOM_B_ON_OFF (รอติดตั้ง ห้อง Server ตึกหลัง)
ไม่มีความคิดเห็น:
แสดงความคิดเห็น