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_address modbus.find_function modbus.find_quantity modbus.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
pass nb_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]))