from simple import MQTTClient

from machine import Pin

import machine

import micropython

import json

#选择G4引脚

g4 = Pin(4, Pin.OUT, value=0)

# MQTT服务器地址域名为:183.230.40.39,不变

SERVER = "183.230.40.39"

#设备ID

CLIENT_ID = "deviceID"

#随便起个名字

TOPIC = b"TurnipRobot"

#产品ID

username='productID'

#产品APIKey:

password='APIKey'

state = 0

#要上报的数据点

message = {'datastreams':[{

'id':'temperature',

'datapoints':[{'value':35}]}

]}

def pubdata(data):

j_d = json.dumps(data)

j_l = len(j_d)

arr = bytearray(j_l + 3)

arr[0] = 1 #publish数据类型为json

arr[1] = int(j_l / 256) # json数据长度 高位字节

arr[2] = j_l % 256 # json数据长度 低位字节

arr[3:] = j_d.encode('ascii') # json数据

return arr

def sub_cb(topic, msg):

global state

print((topic, msg))

if msg == b"on":

g4.value(1)

state = 1

print("1")

elif msg == b"off":

g4.value(0)

state = 0

print("0")

elif msg == b"toggle":

state = 1 - state

g4.value(state)

def main(server=SERVER):

#端口号为:6002

c = MQTTClient(CLIENT_ID, server,6002,username,password)

c.set_callback(sub_cb)

c.connect()

c.subscribe(TOPIC)

print("Connected to %s, subscribed to %s topic" % (server, TOPIC))

#publish报文上传数据点

c.publish('$dp',pubdata(message))

print('publish message:',message)

try:

while 1:

c.wait_msg()

finally:

c.disconnect()

def pubdata(data):

j_d = json.dumps(data)

j_l = len(j_d)

arr = bytearray(j_l + 3)

arr[0] = 1 #publish数据类型为json

arr[1] = int(j_l / 256) # json数据长度 高位字节

arr[2] = j_l % 256 # json数据长度 低位字节

arr[3:] = j_d.encode('ascii') # json数据

return arr

找到设备管理页面,在tpyboardv202设备信息的操作列中,点击[查看详情]。

选择[数据展示],

选择数据流[temperature]信息行的最右侧展开小三角,查看详细数据点。

到此,相信大家对“如何使用MQTT协议上传数据点到OneNET平台”有了更深的了解,不妨来实际操作一番吧!这里是本站网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!