介绍

该模块作为云服务接口与业务接口的中间件, 不单独进行使用, 需和业务模块功能与云服务模块功能结合使用

1.模块导入

  1. from remote import RemoteSubscribe
  2. remote_sub = RemoteSubscribe()

2. 添加业务处理模块对象

  1. class CloudExecutor(object):
  2.     pass
  4. cloud_executor = CloudExecutor()
  5. res = remote_sub.add_executor(cloud_executor)

3. 注册为云服务模块监听者

  1. from aliyunIot import AliYunIot
  2. ali = AliYunIot(pk, ps, dk, ds, server, client_id)
  3. ali.addObserver(remote_sub)
  5. # 阿里云模块接收到服务端下发消息后整合之后调用该模块的execute接口将消息通知给该模块
  6. remote_sub.execute(ali, *args, **kwargs)