通过MQTT连接及收发消息 IoT Core 支持通过 MQTT 协议( v3.1.1)使用。当前支持QoS0和1的消息。 获取 MQTT 连接信息 在设备详情页,连接信息栏目,找到「DeviceSecret」字段,点击右侧小眼睛图标,查看连接信息,包含IoTCoreId、DeviceKey 和 DeviceSecret 或证书。
删除权限 该接口用于删除集群中指定的权限信息。 使用该接口时集群需要开启权限管理。 集群处于服务中状态(ACTIVE)。 请求结构 DELETE / v { version } / clusters / { clusterId } / acls ? username = { username } & patternType = { patternType } & resourceT
创建用户 该接口用于在集群中创建用户。 使用该接口时集群需要开启SASL身份认证。 集群处于服务中状态(ACTIVE)。 请求结构 POST / v { version } / clusters / { clusterId } / users HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorizat
启动集群 该接口用于启动集群。 请求结构 PUT / v { version } / clusters / { clusterId } / start HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是
暂停任务 该接口用于暂停集群中已经启动的任务。 目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 只有任务状态为RUNNING(执行中)的情况下才能够暂停任务。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / suspend HTTP / 1.1 Host : kafka -
停止集群 该接口用于停止集群。 请求结构 PUT / v { version } / clusters / { clusterId } / stop HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : authorization string 请求头域 除公共头域外,无其他特殊头域。 请求参数 参数名称 类型 是否
删除主题 该接口用于删除集群中的主题(topic)。 集群处于服务中状态(ACTIVE)。 请求结构 DELETE / v { version } / clusters / { clusterId } / topics / { topicName } HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorization : author
取消任务 该接口用于取消集群中的任务。 目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 目前只有当主题调整任务设置为自定义执行时间,并且任务没有开始执行才能够取消任务。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / cancel HTTP / 1.1 Host : kaf
模型定义 TopicCreateParameters 参数名称 类型 描述 topicName String topic名称,只能包含大小写英文字母,数字,下划线 _ ,横行 - ,不能使用双下划线 __ partitionCount int topic分区数,最少1个,最多10个 Topic 参数名称 类型 描述 topicName String topic名称 partitionCount I
启动任务 该接口用于启动集群中的任务。 目前支持的任务类型只有:REASSIGN_PARTITION(主题调整)。 请求结构 PUT / v { version } / clusters / { clusterId } / jobs / { jobId } / start HTTP / 1.1 Host : kafka - api . bj . baidubce . com Authorizati