Test the MQTT connection
from m5stack import *
from m5ui import *
from uiflow import *
import module
setScreenColor(0x222222)
nb_topic = None
nb_msg = None
nbiot = module.get(module.NBIOT)
def iotbase_mqtt_cb(nb_mq_topic, nb_mq_payload):
  global nb_topic, nb_msg
  nb_topic = nb_mq_topic
  nb_msg = nb_mq_payload
  print(nb_topic)
  print(nb_msg)
  pass
nbiot.mqtt_to_connect('mqtt.m5stack.com', 1883, '', '', '', 120)
nbiot.mqtt_publish('subscribe', '', 0)
while True:
  if nbiot.mqtt_check_connection():
    print(nbiot.at_command_tester('AT', 'OK', 1000, 0))
  wait_ms(2)nbiot.get_gprs_network_registration()nbiot.get_network_registration()nbiot.get_single_quality()nbiot.check_status()nbiot.coap_destroy()nbiot.coap_get('/m5stack-get')nbiot.coap_to_connect('120.77.157.90', 5683)nbiot.coap_post('/m5stack-post', '', content_format=0)nbiot.coap_put('/m5stack-put', '', content_format=0)nbiot.get_ezdata(ezdata_get_NRZBHcb, 'GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '')nbiot.remove_ezdata('GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '')nbiot.set_ezdata('GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '', '', 0)nbiot.get_CCID()nbiot.get_IMEI()nbiot.modbus_init(15, 13, 115200, 1, 1)modbus.read_coils(1, 1, 0)modbus.read_discrete_inputs(1, 1, 0)modbus.read_holding_registers(1, 1, 0, True)modbus.read_input_registers(1, 1, 0, True)modbus.write_multiple_coils(1, 1, 0)modbus.write_multiple_registers(1, 1, 0, True)option to write signed data.
modbus.write_single_coil(1, 1, 0)modbus.write_single_register(1, 1, 0, True)print((str('code:') + str((1))))modbus.find_addressmodbus.find_functionmodbus.find_quantitymodbus.function_init(1, 0, 0)modbus.receive_req_create_pdu()modbus.create_slave_response(1)modbus.update_process(1, 0, 0, [0, 0, 0])nbiot.modem_power(True)nbiot.mqtt_check_connection()nbiot.mqtt_to_connect('mqtt.m5stack.com', 1883, '', '', '', 120)nbiot.mqtt_disconnect()nbiot.mqtt_poll()nbiot.mqtt_publish('', '', 0)nbiot.mqtt_subscribe('', iotbase_mqtt_cb, 0)def iotbase_mqtt_cb(nb_mq_topic, nb_mq_payload):
  global ezdata_value1, nb_topic, nb_msg
  nb_topic = nb_mq_topic
  nb_msg = nb_mq_payload
  passnb_topic and nb_msg are used to get the topic and message content.nbiot.mqtt_unsubscribe('')nbiot.poweroff()nbiot.reset()nbiot.set_command_echo_mode(0)<img class="blockly_svg" src="https://m5stack.oss-cn-shenzhen.aliy
uncs.com/resource/docs/static/assets/img/uiflow/blockly/modules/iot_base_nb/uiflow_block_iotbase_uart_any.svg">
modbus._mdbus_uart.any()modbus._mdbus_uart.read()modbus._mdbus_uart.readline()modbus._mdbus_uart.read(10)modbus._mdbus_uart.write('')modbus._mdbus_uart.write(''+"\r\n")modbus._mdbus_uart.write(bytes([0, 0, 0]))