创建和管理资源队列 概述 托管资源池资源队列是算力资源分配调度的单元,所有使用托管资源池算力的工作负载都需要提交到对应的资源队列中才能获得算力分配。本文将介绍如何创建和管理资源队列。 创建资源队列 登录 百舸异构计算平台AIHC控制台 。 在左侧菜单栏选择托管资源池,进入托管资源池页面,选择 资源队列 ,点击 新建资源队列 。 在创建资源队列页面,根据实际需求完成相关参数配置。
如果无时钟服务,可以不用传入正确的时间戳,但必须传入0进行占位且在组合username时不传入对应timestamp值。 algorithm_type 字符串签名算法类型,取值 MD5 或 SHA256 device_secret 平台提供的密钥 2、进行加密 使用MD5或者SHA256,对加密字符串进行加密。
方法 API 说明 POST /pub 发布消息 请求参数 参数名称 是否必须 说明 CustomOptions 必选 option取值当前只有一种: 2080: 标识token,取值为设备认证后返回的token值 (说明:每次上报数据都需要携带token信息,如果token失效,需要重新进行设备认证,获取token) topic 必选 消息需要发送到的主题 qos 必选 消息qos,支持0或者1
MessagePublishRateQueue 队列发布消息速度 条/秒 InstanceId,QueueName Messages 实例消息数 条 InstanceId MessagesReady 实例可消费消息数 条 InstanceId MessagesReadyQueue 队列可消费消息数 条 InstanceId,QueueName MessagesUnacknowledged 实例未确认消息数
通过MQTT连接及收发消息 IoT Core 支持通过 MQTT 协议( v3.1.1)使用。当前支持QoS0和1的消息。 获取 MQTT 连接信息 在设备详情页,连接信息栏目,找到「DeviceSecret」字段,点击右侧小眼睛图标,查看连接信息,包含IoTCoreId、DeviceKey 和 DeviceSecret 或证书。
Messages might be lost silently on error. # 代理要求的ACK可靠性级别 # 0=无响应,1=等待本地提交,-1=等待所有副本提交 # 默认值是1 # 注意:如果设置为0,Kafka不会返回任何ack。出错时,消息可能会悄无声息地丢失。
目前最高提供了上限为 2400MBps 流量下的推荐配置,如果业务需要更高流量,请提交工单进行咨询。
业务突发削峰 在类似电商秒杀、春节活动等业务突发时,传统架构下系统的压力即为用户的请求压力,使用消息队列架构变化队列长度对用户的请求压力实现削峰,有效保障业务系统不被打死,业务可持续。 适用的领域: 电商、新闻门户等存在周期性尖峰的业务。
由于消息是以队列的形式缓存在Kafka中,分区个数并不需要按照峰值来设置,而只要按照平均值来设置即可,当然缺点是延时会提高。 什么是客户端? 您可以通过Kafka客户端连接消息中心,并且把代码部署在多个百度智能云服务BCC或应用引擎BAE实例中生产或者消费消息。
消息查询 操作场景 用于在控制台中根据时间或者位点来查询主题中的消息。 注意事项 支持查询结果最多显示20条消息,且总大小不超过10MB。 每10秒可查询一次。 操作步骤 登录 消息服务 for Kafka控制台 进入集群列表页面,点击需要操作的集群。 在 消息查询 页面选择所要查询的主题、查询方式、分区、起始位点/时间等信息进行查询,并且点击右上角的下载按钮可以将本次查询到的消息下载到本地。