Version 9 (modified by 12 days ago) (diff) | ,
---|
Mosquitto sub/pub
We sub and put in queue then create thread to read the queue mosq_feed_ex.py
Test with for loop in bash
[krit@mini Mqtt]$ for i in {1..10}; do mosquitto_pub -h mq1.mycompany.com -u userName -P mypassword -t "/mycompany/ActDAS/test" -m "{\"id\": $i}"; done
Mosquitto sub cmd
We sub for waiting cmd pub from client using this mosq_sub_cmd_v1.py
~]$ mosquitto_pub -h host -u user1 -P pass1234 -t 'kmitlt108/cmd' -m '{"id":1, "cmd":"echo 1 > /tmp/out.txt"}'
Then, put this script mosq_sub_cmd.service in /etc/systemd/system/mosq_sub_cmd.service
~]# systemctl daemon-reload ~]# systemctl enable mosq_sub_cmd.service ~]# systemctl start mosq_sub_cmd.service ~]# systemctl status mosq_sub_cmd.service
Attachments (3)
- mosq_feed_ex.py (6.8 KB) - added by 3 years ago.
- mosq_sub_cmd_v1.py (2.7 KB) - added by 12 days ago.
- mosq_sub_cmd.service (527 bytes) - added by 12 days ago.
Download all attachments as: .zip