IoTReplicator
IoTReplicator 对象管理一端与 *IoTCommunicator *接口,另一端与数据库接口的复制进程。
IoTReplicator(...) | 构造函数:创建一个 IoTReplicator 实例 |
connect(...) | 与一个 IoTCommunicator 连接 |
sync(agent_id, flags) | 与服务器数据库执行同步操作 |
clear(agent_id) | 删除由 agent_id 标识的对等方已传输并确认的数据 |
clear_class(agent_id, class_name) | 仅删除由 agent_id 标识的对等方已传输并确认的指定类的数据 |
stop() | 停止复制器 |
enum_agents(callback_fn) | 枚举此复制器的活动连接。为每个连接调用回调函数。函数签名必须如下所示: def iot_enum_agents_callback(repl, comm): pass |
destroy() | 销毁底层的复制器对象 |
属性 | |
agent_id | 节点的 agent_id |
level | 节点的层级 |
comm | 节点的底层 IoTCommunicator 对象 |