FIFO 策略) or BestEffortFIFO(遍历策略) opend Bool 否 Body 参数 true 开启队列;false 关闭队列;默认开启队列 返回头域 除公共头域外,无其它特殊头域。
请求参数 参数名称 类型 是否必须 参数位置 说明 resourcePoolId String 是 Path参数 标识资源池的唯一标识符 description String 否 Body参数 队列描述 name String 是 Body参数 队列名称 queueType String 否 Body参数 队列类型,当前支持 Regular(普通队列)、Elastic(弹性队列)和 Physical
ConsumerMessagesOutPerSec 消费消息数量速率 条/s ClusterId, ConsumerGroup ConsumerBytesOutPerSec 消费消息流量速率 Bytes/s ClusterId, ConsumerGroup ConsumerQueueingLatencyMs 消息排队时间 ms ClusterId, ConsumerGroup Lag 消息堆积量
删除队列 描述 删除队列,目前支持删除托管资源队列。 请求结构 Plain Text 复制 1 POST ?
节点监控 表3 节点监控消息指标说明 英文名称 中文名称 单位中英文 维度 BrokerConnectionCount 节点连接数量 个 ClusterId,BrokerId BrokerChannelCount 节点通道数量 个 ClusterId,BrokerId BrokerQueueCount 节点队列数量 个 ClusterId,BrokerId BrokerConsumerCount
由于消息是以队列的形式缓存在Kafka中,分区个数并不需要按照峰值来设置,而只要按照平均值来设置即可,当然缺点是延时会提高。 什么是客户端? 您可以通过Kafka客户端连接消息中心,并且把代码部署在多个百度智能云服务BCC或应用引擎BAE实例中生产或者消费消息。
删除队列 描述 删除指定队列 请求结构 Bash 复制 1 DELETE /api/v1/resourcepools/ { resourcePoolId } /queue/ { queueName } 2 Host:aihc.bj.baidubce.com 3 Authorization:authorization string 4 ContentType: application/json 请求头域
管理队列 CHPC支持将运行不同作业或执行不同任务的计算节点进行分类,便于筛选节点。 本文介绍如何在CHPC管理控制台创建队列、将节点加入队列和删除队列。 创建队列 登录CHPC控制台: https://console.bce.baidu.com/chpc/# 在顶部菜单栏左上角处,选择地域。 在左侧导航栏,选择队列管理。 在上方选择目标集群。 单击『创建队列』。
查询队列详情 描述 获取指定队列详情,包括队列基本信息以及资源使用量等 请求结构 Bash 复制 1 GET /api/v1/resourcepools/ { resourcePoolId } /queue/ { queueName } 2 Host:aihc.bj.baidubce.com 3 Authorization:authorization string 4 ContentType: application
TopicMessagesOutPerSec % 主题 消费流量速率 TopicBytesOutPerSec % 主题 消费组监控支持按照时间、监控类型(基础监控或消费组主题)、消费组筛选 指标名称 指标英文名称(metric name) 单位 维度 消息堆积量 ConsumerLag GB 消费组 消费消息数量速率 ConsumerMessagesOutPerSec % 消费组 消费消息流量速率