UIFlow 上手教程
UiFlow1 快速上手
UiFlow1 Blockly
Event
UI
Unit
Module
Hat
UiFlow2 快速上手
Hat CBack Nbiot
案例程序
该程序通过 MQTT 连接服务器，订阅特定主题，在按钮 A 被按下时生成一个随机数并发布到主题中，同时显示在串口上。
from m5stack import *
from m5ui import *
from uiflow import *
import hat
setScreenColor(0xffffff)
nb = hat.get(hat.CBACK_NBIOT)
nb_topic = None
nb_msg = None
counter = None
previous = None
import random
def hat_cbacknbiot_mqtt_cb(nb_mq_topic, nb_mq_payload):
global nb_topic, nb_msg, counter, previous
nb_topic = nb_mq_topic
nb_msg = nb_mq_payload
print(nb_topic)
print(nb_msg)
pass
def buttonA_wasPressed():
global nb_topic, nb_msg, counter, previous
counter = random.randint(100000, 999999)
print(counter)
label2.setText(str(counter))
pass
btnA.wasPressed(buttonA_wasPressed)
counter = 0
previous = 0
nb.mqtt_to_connect('mqtt.m5stack.com', 1883, 'm5_mqtt999', '', '', 120)
if nb.mqtt_check_connection():
print('Connected')
while not (nb.mqtt_subscribe('SubTopic', hat_cbacknbiot_mqtt_cb, 0)):
nb.mqtt_unsubscribe('SubTopic')
print('Subscribed')
while True:
nb.mqtt_poll()
if counter != previous:
nb.mqtt_publish('PubTopic', str(counter), 0)
previous = counter
wait_ms(2)
功能说明
print((str('ip:') + str((nb.coap_to_connect('120.77.157.90', 5683)))))- 使用 IP 设置初始化 CoAP
def ezdata_get_jsdbZcb(value):
global ezdata_value1
ezdata_value1 = value
pass
nb.get_ezdata(ezdata_get_jsdbZcb, 'wCGubMfa3ExoVXuEzuYQy4zm7cumT5FI', '')- 从 ezdata 异步获取值
print((str('registration:') + str((nb.get_gprs_network_registration()))))- 检查 GPRS 网络注册状态
print((str('registration:') + str((nb.get_network_registration()))))- 检查网络注册状态
print((str('quality:') + str((nb.get_single_quality()))))- 评估信号质量
print((str('status:') + str((nb.check_status()))))- 检查设备状态
print(nb.coap_destroy())- 销毁 CoAP 资源
print((str('get:') + str((nb.coap_get('/m5stack-get')))))- 检索 CoAP 数据
print((str('post:') + str((nb.coap_post('/m5stack-post', '', content_format=0)))))- 提交 CoAP 数据
print((str('put:') + str((nb.coap_put('/m5stack-put', '', content_format=0)))))- 更新 CoAP 数据
nb.destroy_https()- 销毁 HTTPS 连接
print((str('connect:') + str((nb.disconnect_server()))))- 断开服务器连接
nb.remove_ezdata('wCGubMfa3ExoVXuEzuYQy4zm7cumT5FI', '')- 从 ezdata 中移除数据
nb.set_ezdata('wCGubMfa3ExoVXuEzuYQy4zm7cumT5FI', '', '', 0)- 将数据保存到 ezdata
print(nb.get_CCID())- 检索 CCID
print(nb.get_IMEI())- 检索 IMEI
print((str('http:') + str((nb.http_service(0, '', '', 'application/json', '')))))- HTTP 服务
nb.modem_power(True)- 调制解调器电源控制
print(nb.mqtt_check_connection())- 检查 MQTT 连接状态
nb.mqtt_to_connect('mqtt.m5stack.com', 1883, '', '', '', 120)- 建立 MQTT 连接
nb.mqtt_disconnect()- 断开 MQTT 连接
nb.mqtt_poll()- 轮询 MQTT 消息
nb.mqtt_publish('', '', 0)- 发布 MQTT 消息
print((str('mqtt:') + str((nb.mqtt_subscribe('', hat_cbacknbiot_mqtt_cb, 0)))))- 订阅 MQTT 主题
def hat_cbacknbiot_mqtt_cb(nb_mq_topic, nb_mq_payload):
global nb_topic, nb_msg
nb_topic = nb_mq_topic
nb_msg = nb_mq_payload
pass- 设置 MQTT 订阅回调
nb.mqtt_unsubscribe('')- 取消订阅 MQTT 主题
nb.poweroff()- 关闭模块电源
nb.reset()- 重置模块
print((str('status:') + str((nb.set_command_echo_mode(0)))))- 设置回显模式