如果消息消费异常，您可以在 SOFAStack 消息队列控制台查看消费者状态，进行问题排查。本文介绍如何查看消费者状态。查看 Group ID 消费者状态 登录 SOFAStack 控制台。在左侧导航栏，选择 中间件 消息队列 Group 管理。单击目标 Group ID ...
消费者 消费者是指从队列服务中订阅数据的客户端程序，当客户端使用Watch API进行数据调用时，会在队列服务中生成消费者对象。API中的参数（如Window的大小、Tags），将作为消费者的属性。通过Attribute API查看消费者状态，示例如下：[OK]...
AI 网关通过消费者来为路由、API开启认证能力，本文介绍AI网关控制台如何管理消费者。操作步骤 登录 AI网关控制台。在左侧导航栏，单击 消费者，并在顶部菜单栏选择地域。在 消费者 页面左上角，单击 创建消费者。在 创建消费者 页面，填写...
在 消费者 区域单击 授权，在消费者下拉框中选择消费者，您也可以单击 管理消费者 为新的消费者进行授权。最后单击 添加。相关文档 如何创建消费者、授权消费者。具体详情，请参见 管理消费者、授权管理。消费者如何通过认证和鉴权实现安全...
在 消费者 区域单击 授权，在消费者下拉框中选择消费者，您也可以单击 管理消费者 为新的消费者进行授权。最后单击 添加。相关文档 如何创建消费者、授权消费者。具体详情，请参见 管理消费者、授权管理。消费者如何通过认证和鉴权实现安全...
AI 网关支持为MCP服务和MCP工具配置消费者认证。通过API key的认证方式验证调用者的身份，精准控制 API 访问权限，实现多租户细粒度管控，保障敏感数据隔离与合规调用，有效防止未授权访问和资源滥用。本文为您介绍如何配置消费者认证。...
本文旨在为您介绍如何在云原生API网关中管理消费者并进行授权管理。管理消费者 云原生API网关通过消费者来为路由、API 开启认证能力，从而实现对访问请求的精细化权限控制。每个消费者可以被分配独立的身份标识和授权策略，确保只有经过...
云原生API网关通过消费者来为路由、API开启认证能力，本文介绍云原生API网关控制台如何管理消费者。创建消费者 云原生API网关为您提供了三种认证方式。配置方式 说明 场景适用 API Key 客户端需将凭证按指定方式添加到请求中，网关验证其...
例如一个消费者的Prefetch Count参数为100条，每条消息需要30秒，则处理完这一批消息需要3000秒，而最长消费时间只有300秒，这样每个消费者只有前10条消息能够被正常消费，后续所有消息都将消费失败，消息将出现堆积。解决办法 通过如下...
在线画像分析服务如果按照这样的数据模型组织标签数据，不可避免的需要Join多张标签表来完成多标签的过滤，这对于数据库产品开销太大。方案介绍 Hologres标签宽表的方案是指将相对稳定的属性表离线聚合成宽表，将多张表的关联操作转化成对...
本案例以简单的网站用户画像分析为例，带您熟悉DataWorks的主要功能和常见任务，主要包含同步数据、加工数据、管理数据以及消费数据操作。案例目标 案例 预期 通过本案例的实操，您将能够在DataWorks中独立完成数据同步、数据开发和任务运...
本文介绍如何通过对API消费者进行授权管理，确保只有经过身份验证和权限校验的请求才能访问服务资源。授权消费者 登录 AI网关控制台。在左侧导航栏，单击 消费者，并在顶部菜单栏选择地域。在 消费者 页面，单击目标消费者进入详情页，选择...
本文介绍如何通过对API消费者进行授权管理，确保只有经过身份验证和权限校验的请求才能访问服务资源。授权消费者 登录 云原生API网关控制台。在左侧导航栏，选择 消费者，并在顶部菜单栏选择地域。在 消费者 页面，单击目标消费者进入详情...
不可见状态：当消费者接收了一条消息后，这条消息会进入不可见状态，意味着其他消费者在此期间无法接收到这条消息，以免消息被多个消费者同时处理。可见性超时时间：是指从消费者接收消息开始到允许其它消费者再次接收该消息的时间段。当...
消费者管理 API 标题 API概述 RemoveConsumerAuthorizationRule 删除消费者授权规则 删除消费者授权规则 QueryConsumerAuthorizationRules 查询消费者授权规则列表 查询消费者授权规则列表 CreateConsumerAuthorizationRules 创建消费者...
消费者管理 API 标题 API概述 RemoveConsumerAuthorizationRule 删除消费者授权规则 删除消费者授权规则 QueryConsumerAuthorizationRules 查询消费者授权规则列表 查询消费者授权规则列表 CreateConsumerAuthorizationRules 创建消费者...
不可见状态：当消费者接收了一条消息后，这条消息会进入不可见状态，意味着其他消费者在此期间无法接收到这条消息，以免消息被多个消费者同时处理。可见性超时时间（Visibility Timeout）可见性超时时间：是指从消费者接收消息开始到允许...
灰度发布操作路径 场景1 灰度消费者常态化部署 在长期部署灰度消息消费者的场景中，只需将生产者与消费者接入微服务治理，并开启消息灰度功能，即可实现灰度消息由灰度消费者处理、基线消息由基线消费者处理的目标。整个过程通过一次简单...
Model API消费者鉴权通过API key的认证方式验证调用者的身份，精准控制 API 访问权限，实现多租户细粒度管控，保障敏感数据隔离与合规调用，有效防止未授权访问和资源滥用。策略说明 安全性：防止未授权访问：消费者鉴权通过验证请求者的...
实例查询行为画像分析 对单独实例的查询行为进行了统计分析，主要统计指标包括：用户在某段时间内的查询次数；用户查询是否包含join、agg或者sort等；用户第一次和最后一次查询的时间；用户查询在X%以上属于哪类查询。实例时序数据分析 ...
消费者分组 API 标题 API概述 CreateConsumerGroup 创建消费者分组 创建云消息队列 RocketMQ 版的消费者分组（ConsumerGroup）。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定...
Agent API消费者认证通过API key和JWT的认证方式验证调用者的身份，精准控制 API 访问权限，实现多租户细粒度管控，保障敏感数据隔离与合规调用，有效防止未授权访问和资源滥用。策略说明 安全性：防止未授权访问：消费者鉴权通过验证请求...
消费进度：云消息队列 RocketMQ 版服务端默认提供订阅关系持久化的能力，即消费者分组在服务端注册订阅关系后，当消费者离线并再次上线后，可以获取离线前的消费进度并继续消费。Topic和ConsumerGroup的映射关系 一个Topic可以被多个...
云消息队列 RocketMQ 版 支持Push型消费者和Simple型消费者这两种类型的消费者，本文分别从使用方式、实现原理、可靠性重试和适用场景等方面为您介绍这两种类型的消费者。背景信息 云消息队列 RocketMQ 版 面向不同的业务场景提供了不同...
如果消息消费出现异常，您可以在 云消息队列 RocketMQ 版 控制台查看指定Group ID的消费状态，包括消费者在线状态、订阅关系一致性结果、消费堆积相关指标、消费者客户端信息等，帮助您快速定位异常原因。应用场景 消费者状态信息包括在线...
为了防止消息重复消费导致业务处理异常，轻量消息队列（原 MNS）的消费者在接收到消息后，需要根据业务唯一标识对消息做幂等处理。本文介绍消费幂等的概念、适用场景以及处理方法。什么是消费幂等 在消息队列场景中，消费幂等处理是指即使...
云原生网关支持为路由配置认证，并对指定的消费者进行鉴权，以允许对应消费者访问路由。本文介绍如何配置消费者鉴权。重要 本文适用于云原生网关 普通实例标准版、普通实例专业版。背景信息 相比全局认证鉴权适用于统一登录认证等ToC场景，...
每条消息被某个消费者消费完成后不会立即在队列中删除，云消息队列 RocketMQ 版 会基于每个消费者分组维护一份消费记录，该记录指定消费者分组消费某一个队列时，消费过的最新一条消息的位点，即消费位点。当消费者客户端离线，又再次重新...
订阅关系一致指的是同一个消费者 Group ID 下所有消费者实例所订阅的 Topic、Tag 以及对消息的处理逻辑必须完全一致。一旦订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。本文提供订阅关系不一致的示例代码，帮助您顺畅地订阅...
云消息队列 RocketMQ 版 的消息负载均衡策略针对生产者和消费者有所差异。对消费者而言，消息负载均衡策略在一定程度上影响消息堆积。背景信息 随着SDK版本的升级，云消息队列 RocketMQ 版 的负载均衡策略也有所优化，根据SDK版本，负载...
反之，消费者的消息处理速度较慢，但QoS值设置较大，导致消费者无法及时处理完已经推送到消费者客户端的消息，消息会在消费超时时间之后重新入队等待再次推送。因此，请针对每个队列的消费耗时，酌情设置QoS值。详情请参见 消费消息时需要...
消费者分组（ConsumerGroup）消费者分组是 云消息队列 RocketMQ 版 系统中承载多个消费行为一致的消费者的负载均衡分组。和消费者不同，消费者分组并不是运行实体，而是一个逻辑资源。在 云消息队列 RocketMQ 版 中，通过消费者分组内初始...
例如如下配置中，对于所有前缀为AI的消费者，任意防护维度的防护等级为中，精确匹配的AI-TEST消费者模型幻觉防护等级为高，此时由于AI-TEST消费者被两条规则命中，且任意防护维度防护等级为中的规则排在上方，则优先执行该规则，因任意防护...
顺序消费实现原理 RabbitMQ的顺序消费需要“顺序存储”和“单一消费者”两个条件同时满足才能实现。开源 RabbitMQ 实现 单一消费者：开源支持Single Active Consumer模式或Exclusive Consumer模式两种使用方式，开源社区更推荐 Single ...
如何解决和优化消息堆积 提升消费者吞吐能力：增加消费者实例：在同一个 Group 中增加消费者，前提是 Partition 数≥消费者数。增加Partition数：提高并行度。异步处理：将耗时操作异步化，加快poll循环。批量处理：一次处理多条消息。调整...
集群消费和广播消费是 云消息队列 RocketMQ 版 的基本消费模式，您可以在消费者客户端将消费模式设置为集群消费或者广播消费，用于控制同一条消息只能被集群内一个消费者消费到，还是会被集群内每个消费者都消费到。背景信息 云消息队列 ...
应用部署 在消费者主动拉取的消息队列中，由于消费者无法感知泳道相关的服务发现信息，为了确保消息被正确消费，需要确保在任意泳道中合法部署消费者和生产者，如下图：合法部署：在一条泳道中，消息队列的生产者和消费者要么同时存在，...
在数据源模块中配置好所需数据源后，基于产品内置的消费者运营模型，您可以完成企业一方用户标签数据集、行为数据集等的创建，为后续的洞察圈选、营销投放功能提供数据基础。支持创建以下数据集：用户标签数据集：基于用户标签大宽表构建...
阿里云日志服务与全站加速DCDN联合推出日志功能，支持近实时采集DCDN实时日志。日志服务提供实时查询、可视化分析、告警、投递、加工等一站式服务。本文介绍DCDN实时日志相关的...人群画像分析：地理位置分布、终端信息分析、访问来源信息等。
为了防止消息重复消费导致业务处理异常，云消息队列 RocketMQ 版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的...