ack-kube-queue
ack-kube-queue是云原生AI套件提供的任务队列组件，主要围绕着Kube Queue任务队列，结合调度器和Quota系统，提供队列管理、优先级调度、使用弹性配额等功能，帮助您优化Kubernetes中的AI/ML工作负载和批处理工作负载的管理效率和调度性能。...
ALIYUN:AMQP:Queue
ALIYUN:AMQP:Queue类型用于创建Queue。语法 {"Type":"ALIYUN:AMQP:Queue","Properties":{"DeadLetterExchange":String,"MaximumPriority":Number,"InstanceId":String,"ExclusiveState":Boolean,"DeadLetterRoutingKey":String,...
Dashboard
通过该功能，您可以查看企业版和铂金版实例、Vhost、Queue和Exchange的各种指标数据，帮助您及时发现和定位问题。本文介绍Dashboard大盘的指标详情和使用方法。注意事项 支持的实例类型 企业版 铂金版 服务关联角色 查看Dashboard大盘时，...
消息队列
消息队列功能函数 函数名 描述 aos_queue_create()消息队列创建函数（推荐）aos_queue_new()消息队列创建函数（兼容3.1）aos_queue_free()消息队列删除函数 aos_queue_send()向消息队列发送消息函数 aos_queue_recv()从消息队列读取消息...
名词解释
对于设置了自动删除的Queue，如果订阅该Queue的最后一个消费端取消订阅后，那么该Queue将会自动删除。B Binding 一套绑定规则，用于告诉Exchange消息应该被存储到哪个Queue。它的作用是把Exchange和Queue按照路由规则绑定起来。Binding Key...
GetQueueAttributes
Response Body 返回的结果为XML格式，格式为：<Queue>Attribute Element List</Queue>参数名称 类型 示例值 描述 QueueName String demo-queue Queue的名称。CreateTime Long 1250700999 Queue的创建时间，从1970-01-01 00:00:00到现在的...
USER_QUEUE_TABLES
USER_QUEUE_TABLES 视图提供当前用户可访问的所有队列表的信息。名称 类型 说明 queue_table TEXT 队列表的用户指定名称。type CHARACTER VARYING 队列表中存储的数据的类型。object_type TEXT 用户定义的有效负载类型。sort_order ...
DBA_QUEUE_TABLES
DBA_QUEUE_TABLES 视图提供数据库中的所有队列表的相关信息。名称 类型 说明 owner TEXT 队列表所有者的角色名。queue_table TEXT 队列表的用户指定名称。type CHARACTER VARYING 队列表中存储的数据的类型。object_type TEXT 用户定义的...
ALL_QUEUE_TABLES
ALL_QUEUE_TABLES 视图提供数据库中的所有队列表的相关信息。名称 类型 说明 owner TEXT 队列表所有者的角色名。queue_table TEXT 队列表的用户指定名称。type CHARACTER VARYING 队列表中存储的数据的类型。object_type TEXT 用户定义的...
Queue管理
本文介绍使用消息模型时如何进行Queue管理。获取Queue实例 Queue是单个消息队列的抽象概念，对应TimelineStore下单个Identifier的所有消息。获取Queue实例时通过TimelineStore的接口创建。TimelineIdentifier identifier=new ...
YARN指标
Fair AMMemoryUsed yarn_resourcemanager_queue_amUsedResources_memory ResourceManager Fair调度器特定队列application master使用的内存大小，3.X版本依赖。单位：MB。Fair AMVCoresUsed yarn_resourcemanager_queue_amUsedResources_...
alicloud_cen_inter_region_traffic_qos_queue
Provides a Cen Inter Region Traffic Qos Queue resource.For information about Cen Inter Region Traffic Qos Queue and how to use it,see What is Inter Region Traffic Qos Queue.->NOTE:Available since v1.195.0.Example Usage ...
消息存活时间
什么是消息存活时间 在 云消息队列 RabbitMQ 版 中，消息存活时间用于限制消息在Queue中可以存在的时间，如果消息在Queue中存在的时间超过了设置的消息存活时间，消息将会被进行如下处理：若您未给Queue设置死信Exchange，消息将被Queue...
查询消息
云消息队列 RabbitMQ 版 支持按Queue查询和按Message ID查询两种方式，前者适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询场景。后者适用于知道发送消息时设置的Message ID的精确查询场景。使用限制 云消息...
CreateQueue
调用CreateQueue创建Queue。调试 您可以在OpenAPI Explorer中直接运行该接口，免去您计算签名的困扰。运行成功后，OpenAPI Explorer可以自动生成SDK代码示例。请求参数 名称 类型 是否必选 示例值 描述 Action String 是 CreateQueue 系统...
Statement Queue
PolarDB 设计了针对语句的排队（Statement Queue）机制，将语句进行分桶排队，尽量把可能具有相同冲突（例如操作相同行）的语句放在一个桶内排队，减少冲突的开销。背景信息 MySQL的服务层和引擎层在语句并发执行过程中，有很多串行的点...
Statement Queue
如果您的MySQL的服务层和引擎层在语句并发执行过程中冲突较多，可以使用AliSQL提供的Statement Queue功能，该功能针对语句的排队机制，将语句进行分桶排队，尽量把可能具有相同冲突的语句（例如操作相同行）放在一个桶内排队，减少冲突的...
alicloud_cen_inter_region_traffic_qos_queues
This data source provides Cen Inter Region Traffic Qos Queue available to the user.->NOTE:Available in 1.195.0+Example Usage data"alicloud_cen_inter_region_traffic_qos_queues""default"{ ids=["${alicloud_cen_inter_region_...
主题+QueueEndpoint使用手册
my_account=Account(endpoint,accid,acckey,token)queue_name=sys.argv[1]if len(sys.argv)>1 else"MySampleQueue"my_queue=my_account.get_queue(queue_name)queue_meta=QueueMeta()try:queue_url=my_queue.create(queue_meta)print...
Exchange管理
Producer将消息发送到Exchange，由Exchange将消息路由到一个或多个Queue中（或者丢弃）。Exchange根据Routing Key和Binding Key将消息路由到Queue。不同类型的Exchange的路由规则不同。本文介绍如何在 云消息队列 RabbitMQ 版 控制台创建...
基于日志服务的日志说明
Queue 订阅或者消息对应的Queue。描述如下：Action 为 PushMessage、BasicGet 和 DeleteMessage 时，为订阅的Queue。Action 为 BasicReject 时，为被拒绝的消息对应的Queue。Action 为 BasicNack 时，为Nack消息对应的Queue。Property 消息...
线程HAL
normal(default)*/os_thread_priority_aboveNormal=1,/*priority:above normal*/os_thread_priority_high=2,/*priority:high*/os_thread_priority_realtime=3,/*priority:realtime(highest)*/os_thread_priority_error=0x84,/*system ...
CreateQueue
说明 只要Queue设置了 PollingWaitSeconds，针对该Queue的所有（Batch）ReceiveMessage请求在队列无消息时，都将默认进入到Polling等待状态（即长轮询）。如果在PollingWaitSeconds时间内一直保持无消息，则返回MessageNotExist；如果在...
Serverless后付费实例计费说明
计费公式 每小时Queue费用＝实例下创建的Queue的个数（个）×Queue单价（元/个）计算Queue数量时，取指定一小时内，实例下Queue数量的最大值。例如，在一小时内先创建了300个Queue，随后又删除了100个Queue，则这个小时内的Queue费用按照...
全球消息路由
全球消息路由的功能和使用方式和开源Shovel插件保持一致，支持不同实例和Vhost间的Queue到Queue、Queue到Exchange的消息转发。在此基础上，除了可以本地域间消息转发，也可以支持跨地域消息转发，以便您按需同步消息，实现不同实例、不同...
消息队列MQ的审计事件
事件名称 事件含义 CreateBinding 为Exchange绑定Queue或者Exchange。CreateExchange 创建Exchange。CreateQueue 创建Queue。CreateVirtualHost 创建Vhost。DashboardCheckServiceStatus 检查服务开通状态。DashboardList 查询Grafana大盘...
SetQueueAttributes
PollingWaitSeconds Integer 否 0 当Queue消息量为空时，针对该Queue的ReceiveMessage请求最长的等待时间。取值范围：0~30，单位为秒。默认值：0。LoggingEnabled Boolean 否 True 是否开启日志管理功能。取值说明如下：True：启用。False...
alicloud_mns_queues
names-A list of queue names.queues-A list of queues.Each element contains the following attributes:id-The id of the queue,The value is set to name.name-The name of the queue delay_seconds-This attribute defines the length ...
队列使用手册
} catch(ServiceException se){ if(se.getErrorCode().equals("QueueNotExist")){ System.out.println("Queue is not exist.Please create queue before use");} else if(se.getErrorCode().equals("TimeExpired")){ System.out.println(...
AMQP协议返回码
返回码列表 返回码（reply-code）返回信息（reply-text）描述 解决方案 200 no route has mandatory 调用 basicPublish 方法发送消息且设置mandatory=true时，如果Exchange根据自身类型和消息的RoutingKey无法匹配到合适的Queue存储消息，...
Memcg OOM优先级策略功能
mkdir/sys/fs/cgroup/memory/A cd/sys/fs/cgroup/memory/A echo 1>memory.use_priority_oom mkdir/sys/fs/cgroup/memory/B cd/sys/fs/cgroup/memory/B echo 1>memory.use_priority_oom 运行以下命令分别设置A、B节点的memcg OOM优先级值为...
KUDU指标
指标 描述 kudu_rpcs_queue_overflow RPC队列溢出次数。kudu_rpc_incoming_queue_time_mean RPC队列的等待时间的平均值。单位：μs。kudu_rpc_incoming_queue_time_percentile_75 75%的RPC队列的等待时间。单位：μs。kudu_rpc_incoming_...
Python Demo
ReceiptHandle:%s MessageBody:%s MessageID:%s"%(recv_msg.receipt_handle,recv_msg.message_body,recv_msg.message_id))except MNSExceptionBase as e:if e.type="QueueNotExist":print("Queue not exist,please create queue before ...
Python Demo
ReceiptHandle:%s MessageBody:%s MessageID:%s"%(recv_msg.receipt_handle,recv_msg.message_body,recv_msg.message_id))except MNSExceptionBase as e:if e.type="QueueNotExist":print("Queue not exist,please create queue before ...
基础功能
1 SDK原理概述 1.1 原理 SDK 提供一种指令形态的埋点调用方式，您通过对 aplus 环境变量的指令队列 aplus_queue发送指令，由 aplus 环境变量来执行指令，进而完成您的需求，指令格式如下：aplus_queue.push({ 'action':"$APIName",'...
消息轨迹
背景信息 云消息队列 RabbitMQ 版 支持以下查询方式：按Queue查询：适用于只知道消息发送到的Queue，不知道发送消息时设置的Message ID的模糊查询场景。按Message ID查询：适用于知道发送消息时设置的Message ID的精确查询场景。具体操作，...
修改作业优先级
请求语法 PUT/jobs/{id} {"Priority":500 } 属性说明 属性名称 类型 是否必须 描述 Id String 是 作业标识符。Priority int 是 作业优先级，[0-1000]，数值越高优先级越高（仅限于自己的作业列表中的作业）。返回信息 成功 返回200状态码。...
PolarDB MySQL 5.7/8.0中Statement Queue和Inventory ...
概述 对于PolarDB MySQL高并发热点优化，PolarDB MySQL提供了结合Statement Queue和Inventory Hint的使用方式，使用过程中需要注意将对应的Inventory Hint通过DBMS_OUTLN.add_optimizer_outline加入到SQL语句中。本文主要以PolarDB MySQL 5...
使用任务队列ack-kube-queue
任务队列ack-kube-queue旨在管理Kubernetes中的AI/ML工作负载和批处理工作负载。它允许系统管理员使用自定义队列的作业队列管理，以提高队列的灵活性。结合Quota系统，ack-kube-queue自动优化了工作负载和资源配额管理，以便最大化利用集群...
部署异步推理服务
} } } 通过 queue.sink.max_payload_size_kb 或者 queue.source.max_payload_size_kb 分别配置输出队列/输入队列单条数据最大数据体积。{"queue":{"sink":{"max_payload_size_kb":10#配置输出队列单条数据最大体积是10 KB,默认8 kB。},...
- 产品推荐
- 这些文档可能帮助您