update
This commit is contained in:
parent
41b563838c
commit
00bccdb21c
2
MQTT.py
2
MQTT.py
|
@ -33,6 +33,7 @@ class MQTTClient:
|
|||
self.client.subscribe(self.topic)
|
||||
client.publish(info_topic, payload=publish_payload(code=200, msg='成功订阅' + self.topic),
|
||||
qos=0)
|
||||
subprocess.Popen(['/bin/bash /home/pi/agri_xumu/bash/start_push_stream.sh'], shell=True)
|
||||
|
||||
def on_message(self, client, userdata, msg):
|
||||
if not valid(msg, client):
|
||||
|
@ -79,4 +80,5 @@ if __name__ == '__main__':
|
|||
MQTT.client.loop_forever()
|
||||
except Exception as e:
|
||||
# 异常等待时间在进行连接
|
||||
subprocess.Popen(['/bin/bash /home/pi/agri_xumu/bash/stop_push_stream.sh'], shell=True)
|
||||
time.sleep(30)
|
||||
|
|
|
@ -2,8 +2,8 @@
|
|||
directory=/home/pi/agri_xumu/bash
|
||||
command=/usr/bin/bash stream.sh
|
||||
user=pi
|
||||
autostart=true
|
||||
autorestart=true
|
||||
autostart=false
|
||||
autorestart=false
|
||||
redirect_stderr=true
|
||||
stopsignal=TERM
|
||||
stopasgroup=True
|
||||
|
|
Loading…
Reference in New Issue