Atomic PoE Base

案例程序

功能说明

poe.tcp_udp_config('', 0, 1, 1)

• 初始化局域网连接。配置远程 IP 地址、端口号和选择使用的通信协议类型(TCP/UDP)，以及指定设备作为服务器或客户端。

poe.mqtt_config('mqtt.m5stack.com', 1883, '', '', '', 120)

• 初始化 MQTT 服务器连接，包含服务器地址、端口号、客户端 ID、用户名、密码及心跳间隔(keepalive)。

poe.is_available_packet(1)

• 检查当前是否有可用的 TCP 数据包，并返回数据包的数量。

poe.get_ezdata(ezdata_get_KzSyFcb, 'GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '')

• 从指定的 MQTT 话题中获取数据，基于话题名和 token 进行操作。

poe.remove_ezdata('GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '')

• 从 MQTT 服务器中删除指定的话题，使用话题名和 token 进行删除操作。

poe.set_ezdata('GCJ3Ic5h2eXnzV3rT3bBXvrncCaJnART', '', '', 0)

• 将指定的数据保存到某个话题中，并使用 token 进行身份验证。

poe.get_if_config()

• 获取当前网络或设备的配置信息。

poe.http_get('', True)

• 通过 HTTP 或 HTTPS 协议从指定的 URL 获取数据，可以选择获取完整内容或其他方式。

poe.http_post('', 'application/json', '')

• 通过 HTTP 或 HTTPS 协议向指定的 URL 发送数据，数据可以是 JSON、表单等多种格式。

poe.local_ip()

• 获取设备在局域网中的本地 IP 地址。

poe.mqtt_is_connect()

• 检查当前设备是否已成功连接到 MQTT 服务器。

poe.mqtt_connect()

• 连接到指定的 MQTT 服务器。

poe.mqtt_disconnect()

• 断开当前与 MQTT 服务器的连接。

poe.mqtt_poll_loop()

• u 轮询从 MQTT 服务器接收到的下行消息。

poe.mqtt_publish('', '', 0)

• 发布一条消息到指定的 MQTT 主题(topic)。

poe.mqtt_subscribe('', atom_poe_mqtt_cb, 0)

• 订阅指定的 MQTT 主题(topic)，可以指定消息传递的服务质量(QoS)。

def atom_poe_mqtt_cb(poe_mq_topic, poe_mq_payload):
  global ezdata_value1, lan_topic, lan_msg
  lan_topic = poe_mq_topic
  lan_msg = poe_mq_payload
  pass

• 设置一个回调函数，当指定的 MQTT 主题接收到消息时，调用该回调处理消息。

poe.remote_ip()

• 获取远程设备的 IP 地址。

poe.socket_close()

• 关闭当前的网络套接字连接。

poe.tcp_receive_packet(0)

• 接收通过 TCP 协议传输的数据包，并根据指定的字节大小读取数据。

poe.tcp_send_packet('1234')

• 通过 TCP 协议发送数据包，数据内容为指定的字符串或数字。

poe.udp_receive_packet(0)

• 接收通过 UDP 协议传输的数据包，并根据指定的字节大小读取数据。

poe.udp_send_packet('', 0, '')

• 通过 UDP 协议发送数据包，指定目标 IP 地址、端口号和发送的数据内容。