云端消息发布

• 该模块采用监听者设计模式, 该模块继承Observable

  • 相对于业务模块, 该模块作为监听者, 接收业务模块的消息发送信息
  • 相对于云功能模块, 该模块作为被监听者, 当有数据需要进行发送时, 通知云功能模块
  • 同时该模块也作为History模块的被监听者, 当消息发送失败时, 发送失败的数据通知给History模块进行存储

模块导入

示例:

from remote import RemotePublish
remote_pub = RemotePublish()

add_cloud 添加云服务模块

• 示例:

from aliyunIot import AliYunIot
ali = AliYunIot(pk, ps, dk, ds, server, client_id)
res = remote_pub.add_cloud(ali)

• 参数:

• 返回值:

cloud_ota_check OTA升级计划查询

示例:

res = remote_pub.cloud_ota_check()

• 参数:

  无

• 返回值:

cloud_ota_action OTA升级确认

• 示例:

res = remote_pub.cloud_ota_action(action, module)

• 参数:

• 返回值:

cloud_device_report 设备模块版本信息上报

• 示例:

res = remote_pub.cloud_device_report()

• 参数:

  无

• 返回值:

cloud_rrpc_response MQTT同步通信消息应答

• 示例:

res = remote_pub.cloud_rrpc_response(message_id, data)

• 参数:

• 返回值:

post_data 物模型消息发布

当消息发送失败时, 会通知已注册的监听者History进行消息存储

• 示例:

data = {
    "switch": True,
    "energy": 100,
}
res = remote_pub.post_data(data)

• 参数:

• 返回值: