IoTCommunicator构造函数
使用一组可选参数创建一个 IoTCommunicator 实例。
IoTCommunicator(comm_params, on_connect, on_recieve, on_ack, on_disconnect, on_destroy)
参数
comm_params
当指定时,期望使用以下可选键的字典:
- n_callback_threads:处理传入请求的线程数;默认值为 8(整数)
- sock_domain:定义套接字域的标志
- ssl_params:包含 SSL 参数的字典
- send_timeout:网络发送的超时值(整数)
- recv_timeout:网络接收的超时值(整数)
- listen_queue_size:监听套接字队列的最大长度;默认值为 0(表示使用系统定义的最大值)(整数)
- wakeup_port:服务端口的端口号;默认值为 0(表示使用系统定义的端口号)(整数)
on_connect
on_connect 事件的回调函数;期望为具有以下签名的可调用 Python 过程:
def iot_on_connect(iotc):
pass
...
comm.on_connect = iot_on_connect
其中 iotc 是一个 IoTCommunicator 对象。
on_recieve
on_receive 事件的回调函数;期望为具有以下签名的可调用 Python 过程:
def iot_on_receive(iotc):
pass
...
comm.on_receive = iot_on_receive
其中 iotc 是一个 IoTCommunicator 对象。
on_ack
on_ack 事件的回调函数;期望为具有以下签名的可调用 Python 过程:
def iot_on_ack(iotc, ack):
pass
...
comm.on_ack = iot_on_ack
其中,iotc 是一个 IoTCommunicator 对象,ack 是一个描述确认事件的字典,具有以下键:
- seq:这在 mco_iot_replicator_sync() API 函数内部使用,用于实现 MCO_IOT_SYNC_WAIT 模式。(长整型)
- sender_agent_id:发送方的 agent_id(长整型)
- receiver_agent_id:接收方的 agent_id(长整型)
- timestamp:确认的时间(长整型)
- error_code:如果不为空,则为错误代码(整型)
on_disconnect
on_diconnect 事件的回调函数;期望为具有以下签名的可调用 Python 过程:
def iot_on_disconnect(iotc):
pass
...
comm.on_disconnect = iot_on_disconnect
其中 iotc 是一个 IoTCommunicator 对象。
on_destroy
on_destroy 事件的回调函数;期望为具有以下签名的可调用 Python 过程:
def iot_on_destroy(iotc):
pass
...
comm.on_destroy = iot_on_destroy
其中 iotc 是一个 IoTCommunicator 对象。
返回
IoTCommunicator
对象已成功实例化。
Exception
抛出带有适当错误消息的异常。