Python之MQTT报文的订阅和发布

1
2
3
4
5
6
7
8
import paho.mqtt.client as mqtt
import time
import hashlib
import hmac
import json
import serial
import re

1
2
3
PUB_TOPIC = "/sys/" + options['productKey'] + "/" + options[
    'deviceName'] + "/thing/event/property/post"

1
2
3
4
5
6
7
options = {
    'productKey': 'XXX',
    'deviceName': 'XXX',
    'deviceSecret': 'XXXX',
    'regionId': 'cn-shanghai'
}

1
2
client.publish(PUB_TOPIC, payload=str(payload_json), qos=1)

1
2
3
4
5
6
7
8
9
10
11
12
13
def Connect_server():
    timestamp = str(int(time.time()))
    CLIENT_ID = "paho.py|securemode=3,signmethod=hmacsha1,timestamp=" + timestamp + "|"
    CONTENT_STR_FORMAT = "clientIdpaho.pydeviceName" + options[
        'deviceName'] + "productKey" + options[
                             'productKey'] + "timestamp" + timestamp
    # set username/password.
    USER_NAME = options['deviceName'] + "&" + options['productKey']
    PWD = hmacsha1(options['deviceSecret'], CONTENT_STR_FORMAT)
    client = mqtt.Client(client_id=CLIENT_ID, clean_session=False)
    client.username_pw_set(USER_NAME, PWD)
    return client

1
2
3
SUB_TOPIC = "/sys/" + options['productKey'] + "/" + options[
    'deviceName'] + "/thing/event/property/set"

1
2
client.subscribe(SUB_TOPIC, 1)