数据银行推送快速入门
在数据银行进行基于品牌的全域消费者资产管理和分析，以及把人群应用到阿里域内的各种营销渠道，实现线上线下融合消费者分析和线上二次触达，提能提效企业品牌全域消费者运营。本文介绍如何进行数据银行推送设置。前提条件 已通过 人群筛选...
达摩盘概述
您可以将受众ID推送至达摩盘，在达摩盘侧建立品牌全域消费者数据资产，将您的一方受众应用在相关营销渠道。支持推送您创建的受众和公共受众，支持推送6种受众ID类型：手机号、电子邮箱、手机IMEI、手机IDFA、淘宝ID、淘宝昵称，且当加密...
订阅关系（Subscription）
订阅关系判断原则 云消息队列 RocketMQ 版 的订阅关系按照消费者分组和主题粒度设计，因此，一个订阅关系指的是指定某个消费者分组对于某个主题的订阅，判断原则如下：不同消费者分组对于同一个主题的订阅相互独立 如下图所示，消费者分组...
达摩盘推送概述
您可以将受众ID推送至 达摩盘，在达摩盘侧建立品牌全域消费者数据资产，将您的一方受众应用在相关营销渠道。支持推送6种受众ID类型：手机号、电子邮箱、手机IMEI、手机IDFA、淘宝ID、淘宝昵称，且当加密方式为SHA256时仅支持推送手机号。...
查看公开资产
公开资产指在资产运营公开的指标、数据表和API资产。本文介绍如何查看公开的资产。前提条件 需查看指标资产，您已完成以下操作：配置逻辑表关联字段标准。公开与隐藏指标资产。需查看数据表资产，您已完成以下操作：资产注册。物理化逻辑表...
查看公开资产
公开资产指在资产运营公开的指标、数据表和API资产。本文介绍如何查看公开的资产。前提条件 需查看指标资产，您已完成以下操作：配置逻辑表关联字段标准。公开与隐藏指标资产。需查看数据表资产，您已完成以下操作：资产注册。物理化逻辑表...
操作流程
通过操作流程图，便于直观的了解到资产运营需进行的一系列任务。本文介绍运营主要操作流程。流程图及说明 任务项 说明 资产注册 通过注册资产锁定待管理数据资产的范围，以备管理数据资产。系统后台自动完成，查看更多，请参见 资产注册。...
操作流程
通过操作流程图，便于直观的了解到资产运营需进行的一系列任务。本文介绍运营主要操作流程。流程图及说明 任务项 说明 资产注册 通过注册资产锁定待管理数据资产的范围，以备管理数据资产。系统后台自动完成，查看更多，请参见 资产注册。...
查看资产总览
资产总览展示公开及未公开资产的指标看板、数据指标数趋势分析和运营分析。本文介绍如何查看资产总览。前提条件 已在数据建模模块关联指标、维度或度量，具体操作，请参见 配置逻辑表关联字段标准。已在数据建模模块创建逻辑表，并物理化。...
查看资产总览
资产总览展示公开及未公开资产的指标看板、数据指标数趋势分析和运营分析。本文介绍如何查看资产总览。前提条件 已在数据建模模块关联指标、维度或度量，具体操作，请参见 配置逻辑表关联字段标准。已在数据建模模块创建逻辑表，并物理化。...
领域模型概述
消息消费 消费者分组（ConsumerGroup）：云消息队列 RocketMQ 版 发布订阅模型中定义的独立的消费身份分组，用于统一管理底层运行的多个消费者（Consumer）。同一个消费组的多个消费者必须保持消费逻辑和配置一致，共同分担该消费组订阅的...
消费者（Consumer）
内部属性 消费者分组名称 定义：当前消费者关联的消费者分组名称，消费者必须关联到指定的消费者分组，通过消费者分组获取消费行为。更多信息，请参见 消费者分组（ConsumerGroup）。取值：消费者分组为 云消息队列 RocketMQ 版 的逻辑资源...
队列服务订阅推送
在不同的消费者组间，数据会并列地推送给每一个存在的消费者，举例来看：如果您的多个消费者在同一个组内，您可以观察到数据会在这些消费者之间进行均衡地分发，消费者会收到不同的数据。如果您的多个消费者在多个不同的组内，您可以观察到...
API概览
消费者分组 API 标题 API概述 CreateConsumerGroup 创建消费者分组 创建云消息队列 RocketMQ 版的消费者分组（ConsumerGroup）。消费者分组是云消息队列 RocketMQ 版系统中承载多个消费行为一致的消费者的负载均衡分组。消费者需要通过指定...
消费进度管理
每条消息被某个消费者消费完成后不会立即在队列中删除，云消息队列 RocketMQ 版 会基于每个消费者分组维护一份消费记录，该记录指定消费者分组消费某一个队列时，消费过的最新一条消息的位点，即消费位点。当消费者客户端离线，又再次重新...
通过仪表板分析数据
假设您是一家大型互联网新零售企业的数据分析师，您的经理刚刚拿到2019年8月份的月度运营分析数据，他发现近期企业运营状况不佳，8月份毛利额环比前几个月下滑较大，三季度毛利额存在不达标风险。因此，需要您根据订单信息和流量渠道信息等...
查看Rebalance详情
消费出现卡顿，导致消费者心跳超时，触发Rebalance来筛选不健康的消费者。消费时间过慢，超过一定时间（max.poll.interval.ms 设置的值，默认5分钟）未进行Pull拉取消息，则会导致客户端主动离开队列，触发Rebalance。消费者数量过多，为...
订阅关系一致
订阅关系一致指的是同一个消费者 Group ID 下所有消费者实例所订阅的 Topic、Tag 以及对消息的处理逻辑必须完全一致。一旦订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。本文提供订阅关系不一致的示例代码，帮助您顺畅地订阅...
消费幂等
为了防止消息重复消费导致业务处理异常，消息队列RocketMQ版 的消费者在接收到消息后，有必要根据业务上的唯一Key对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
TCP协议客户端大版本发布
该策略可能会出现以下问题：消费者数量比和Queue数量多时，部分消费者获取不到消息的现象。部分消费者异常或者处理缓慢，其他消费者空闲却无法共同分担堆积压力的情况。以消息为粒度进行负载，负载策略更加均衡。避免了队列级负载策略可能...
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
消息幂等
为了防止消息重复消费导致业务处理异常，SOFAStack 消息队列的消费者在接收到消息后，有必要根据业务上的唯一 Key 对消息做幂等处理。本文介绍消息幂等的概念、适用场景以及处理方法。什么是消息幂等 当出现消费者对某条消息重复消费的情况...
配置消息灰度
如果您希望基线环境能够智能地识别其他环境是否存在消费者，在不存在消费者时消费对应环境的消息，在存在消费者时忽略对应环境的消息，请在 未打标环境忽略的标签 中输入 自动识别。说明 应用在开启消息灰度后，需要重启才能生效。未打标...
顺序消息
重要 消费者类型为PushConsumer时，云消息队列 RocketMQ 版 保证消息按照存储顺序一条一条投递给消费者，若消费者类型为SimpleConsumer，则消费者有可能一次拉取多条消息。此时，消息消费的顺序性需要由业务方自行保证。消费者类型的具体...
消费者分组（ConsumerGroup）
使用建议 按照业务合理拆分分组 云消息队列 RocketMQ 版 的消费者和主题是多对多的关系，对于消费者分组的拆分设计，建议遵循以下原则：消费者的投递顺序一致：同一消费者分组下所有消费者的消费投递顺序是相同的，统一都是顺序投递或并发...
如何处理消息堆积
导航栏中选择 消息轨迹，单击 创建查询任务，选择 按 Message ID 查询，输入对应的信息，发现部分消息已发送至Broker节点，但未投递给下游消费者。可能原因 云消息队列 RocketMQ 版 的消息发送至Broker节点后，配置了Group ID的客户端根据...
智能小Q：引领数据消费新范式
能让企业用起来的，才是真正的智能BI。一、引领数据消费新范式 Quick BI接入阿里巴巴通义千问大模型能力打造智能小Q分析助手，...3.金融 金融机构可以使用智能数据分析来评估信用风险、预防欺诈行为，并预估市场风险，保护消费者和机构资产。
智能小Q
能让企业用起来的，才是真正的智能BI。一、引领数据消费新范式 Quick BI接入阿里巴巴通义千问大模型能力打造智能小Q分析助手，...3.金融 金融机构可以使用智能数据分析来评估信用风险、预防欺诈行为，并预估市场风险，保护消费者和机构资产。
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
通过命令行管理多集群服务
方式一：通过新的Service名称访问 服务消费者集群ACK Cluster 2创建ServiceImport后，Fleet实例会在服务消费者集群ACK Cluster 2中，创建一个以 amcs-为前缀的Kubernetes服务代表多集群Service。在服务消费者集群ACK Cluster 2的Client Pod...
应用场景
与达摩盘链路打通，实现品牌自有消费者资产的一方人群和阿里域内消费者资产融合去重，识别可运营消费者资产总量，识别消费者与品牌在不同渠道间的关系深度，识别品牌发展阶段，消费者资产健康度，调整运营策略，有针对性地在阿里妈妈投放...
日常运营
日常运营为企业提供了日常用户运营工具，开启日常运营模版后，运营项目展示在导购小程序中，符合特定运营条件的客户自动展示在导购的运营客户列表，并提供运营说明和运营内容，赋能导购进行1对1客户运营。运营模版分为默认模版与自定义模版...
无损下线
为了避免这种情况的发生，在提供者A接到下线命令即将下线前，对于在等待下线阶段收到的请求，在其返回值中都增加上特殊标记，让消费者A接收到返回值并识别到相关标志后主动拉取一次注册中心服务实例，从而实时感知提供者A最新状态，从而...
死信队列
消费验证 您还可以通过消费验证功能来验证指定的消费者应用是否能接受到消息。说明 消费验证功能仅仅是用于验证客户端的消费逻辑是否正常，并不会影响正常的收消息流程，因此消息的消费状态等信息在消费验证后并不会改变。操作步骤：在展开...
通过消费组消费数据
通过消费组（ConsumerGroup）消费数据有显著优点，您无需关注日志服务的实现细节及消费者之间的负载均衡、故障转移（Failover）等，只需要专注于业务逻辑。前提条件 已创建RAM用户并完成授权。具体操作，请参见 创建RAM用户并完成授权。已...
延时消息
如果您希望消息被投递后延迟一段时间被消费者消费，您可以使用 云消息队列 RabbitMQ 版 的延时消息。云消息队列 RabbitMQ 版 原生支持延时消息，使用方式比开源RabbitMQ更简单。什么是延时消息 延时消息是指在指定时间段之后才被消费者消费...
通过消费组消费数据
通过消费组（ConsumerGroup）消费数据有显著优点，您无需关注日志服务的实现细节及消费者之间的负载均衡、故障转移（Failover）等，只需要专注于业务逻辑。前提条件 已创建RAM用户并完成授权。具体操作，请参见 创建RAM用户及授权。已...
重置消费位点
当消费者出现故障或者消费错误数据时，您可通过重置消费位点将消费位置回滚到之前的某个位点或者指定分区位点，重新开始消费。您也可以将消费位置移动至最新位点，暂时不处理堆积的消息。前提条件 已停止所有Consumer客户端（云消息队列 ...
SOFAMQ 常见问题
上述方式可以查询到消息的具体内容以及消费情况，如果需要追踪一条消息从生产者发出到被消费者消费的整个链路中各个相关节点的时间地点，可以使用消息队列最新的消息轨迹查询功能，具体使用方式请参考 查询消息轨迹。消息队列是否能保证...
从Kafka同步数据
消费者的总数不应超过Topic中的分区数，因为每个分区只能分配一个消费者。kafka_thread_per_consumer 否 指定每个消费者是否启动独立线程进行消费，默认值为0。取值说明如下。0：表示所有消费者共同使用1个线程消费。1：表示每个消费者启动...
- 产品推荐
- 这些文档可能帮助您