集成概述
服务化套件集成方案可以减少虚商伙伴的开发工作量，加速开发进度，因整个套件使用的商业标准与阿里云完全对齐，故不支持个性化配置。OpenAPI集成 BUY页面，阿里云侧梳理商品的整个售卖生命周期，对应做了一套bss接口。所有接入的产品都通过...
什么是新零售智能助理
特点：登录控制台，即开即用，但不支持个性化定制需求。PaaS方案，适合有在线咨询服务需求且有一定研发能力的大中型零售企业/零售平台。特点：可灵活开发，但需要一定研发投入成本。仅提供OpenAPI，API内容详见 API概览。aPaaS方案，适用...
什么是Quick Audience
社交互动：提供多品牌多账号的微信公众号的运营能力，对特定的粉丝群组进行个性化活动触达，完成企业私域流量运营。复购预测：基于用户既往购买行为记录，通过训练算法模型，预测用户在未来指定时间内复购的可能性，找到大量非品牌原核心...
消费者（Consumer）
因此，大部分场景下，单一进程内同一个消费分组只需要初始化唯一的一个消费者即可，开发过程中应避免以相同的配置初始化多个消费者。不建议频繁创建和销毁消费者 云消息队列 RocketMQ 版 的消费者是可以重复利用的底层资源，类似数据库的...
消费者分组（ConsumerGroup）
在 云消息队列 RocketMQ 版 中，通过消费者分组内初始化多个消费者实现消费性能的水平扩展以及高可用容灾。在消费者分组中，统一定义以下消费行为，同一分组下的多个消费者将按照分组内统一的消费行为和负载均衡策略消费消息。订阅关系：云...
消费者分类
使用方式 PushConsumer的使用方式比较固定，在消费者初始化时注册一个消费监听器，并在消费监听器内部实现消息处理逻辑。由 云消息队列 RocketMQ 版 的SDK在后台完成消息获取、触发监听器调用以及进行消息重试处理。示例代码如下：/消费...
基本概念
重置消费位点 以时间轴为坐标，在消息持久化存储的时间范围内，重新设置消费者分组对已订阅主题的消费进度，设置完成后消费者将接收设定时间点之后，由生产者发送到 云消息队列 RocketMQ 版 服务端的消息。更多信息，请参见 重置消费位点。...
集群消费和广播消费
广播消费模式 适用于消费端集群化部署，每条消息需要被集群下的每个消费者处理的场景。具体消费示例如下图所示。注意事项 广播消费模式下不支持顺序消息。广播消费模式下不支持重置消费位点。广播模式下不支持线下联调分组消息。每条消息都...
消息过滤
消费者：消费者在初始化及后续消费流程中通过调用订阅关系注册接口，向服务端上报需要订阅指定主题的哪些消息，即过滤条件。服务端：消费者获取消息时会触发服务端的动态过滤计算，云消息队列 RocketMQ 版 服务端根据消费者上报的过滤条件...
流计算实现细节
每个RDD partition在本批次执行完成后（例如读到指定条数或无新数据），将channel对应的最新消费位点持久化到Meta表对应UUID的行中，即填充EndOffset对应UUID的checkpoints，每个批次结束后，新的批次的StartOffset对应的checkpoints都能够...
用户洞察概述
提供多种（AnalyticDB MySQL 2.0、AnalyticDB MySQL 3.0、AnalyticDB PostgreSQL）的数据源的对接能力，用户可以基于此连接自己的消费者数据集，并基于产品内置的规则构建消费者运营模型（AIPL/RMF模型），快速完成消费者的结构化分层，为...
趣店
消费金融行业发展：随着金融科技行业的发展逐步改变用户习惯，以及金融客户年轻化，互联网化的趋势2018年消费金融行业有望持续增长，市场规模将进一步扩大。持牌消费金融快速开业：消费金融行业竞争节奏快，互联网化特征明显，客户从获取...
订阅关系（Subscription）
消费状态：云消息队列 RocketMQ 版 服务端默认提供订阅关系持久化的能力，即消费者分组在服务端注册订阅关系后，当消费者离线并再次上线后，可以获取离线前的消费进度并继续消费。订阅关系判断原则 云消息队列 RocketMQ 版 的订阅关系按照...
队列服务订阅推送
您可以通过Attribute API看到队列服务中的消费者状态，格式化的示例如下：groups.list.[0]:Id:default_group,Index:0,Pending:0,Delivered:0,Consumers:1 groups.list.[1]:Id:group,Index:0,Pending:0,Delivered:1,Consumers:0 groups.list...
查看订阅关系
单元化说明 在 LDC 单元化架构环境下，可以自由切换单元，查看指定单元下该 Topic 被哪些 Group ID 订阅了，如下图所示。查看 Group ID 订阅的 Topic 前提条件 需查询的 Group ID 处于在线状态。操作步骤 在左侧导航栏，选择 中间件>消息...
顺序消息
但一般业务场景下，同一个生产者可能对接多个下游消费者，不一定所有的消费者业务都需要顺序消费，您可以将生产顺序性和消费顺序性进行差异化组合，应用于不同的业务场景。例如发送顺序消息，但使用非顺序的并发消费方式来提高吞吐能力。更...
重置消费位点
您可通过重置消费位点，按需清除堆积的或不想消费的这部分消息再从最新位点开始消费，或直接跳转到某个时间点消费该时间点之后...单元化说明 在 LDC 单元化架构环境中，进行重置消费位点操作时，需要选择重置消费位点的具体单元，如下图所示。
快速开始
当Tunnel处于增量阶段时，如果增量数据超过7天没有消费，Tunnel会从最近可以消费的数据开始消费，因此可能会出现漏消费数据风险。说明 如果增量数据超过7天（具体值和数据表的Stream的日志过期时间一致）没有消费，则数据会出现过期的情况...
通过SDK使用通道服务
当Tunnel处于增量阶段时，如果增量数据超过7天没有消费，Tunnel会从最近可以消费的数据开始消费，因此可能会出现漏消费数据风险。说明 如果增量数据超过7天（具体值和数据表的Stream的日志过期时间一致）没有消费，则数据会出现过期的情况...
概念建模概述
概念建模是Dataphin提供构建业务模型的工具，您可通过Dataphin的建模能力直接在Dataphin构建业务模型，快速将业务理解落地到中台，实现建模/数仓一体化。同时有利于数据消费者更好理解数据和数据对应的业务。本文为您介绍Dataphin数仓规划...
查看账单
本文介绍如何查看 可观测可视化 Grafana 版 的费用账单。...在账单列表中单击 产品 右侧的 图标，选择 可观测可视化 Grafana 版，查看Grafana的消费账单。单击 消费类型、账单类型 和 支付状态 右侧的 图标，可进一步筛选您的消费账单。
查看账单
本文介绍如何查看 可观测可视化 Grafana 版 的费用账单。...在账单列表中单击 产品 右侧的 图标，选择 可观测可视化 Grafana 版，查看Grafana的消费账单。单击 消费类型、账单类型 和 支付状态 右侧的 图标，可进一步筛选您的消费账单。
版本说明
本发布说明（Release notes）按照时间倒序方式提供了 SOFAStack 消息队列发布后的更新情况...提供简单易用的可视化 Web 控制台管理工具，支持 创建和管理 Topic、创建和管理 Group ID、查看订阅关系、重置消费位点、消息查询、查询消息轨迹。
实时消费概述
功能优势 实时消费具有以下优势：数据集中 日志服务已完成不同机器上的数据集中化，您只需通过SDK实时消费采集到日志服务的数据。分类管理 您可以利用日志服务的数据分类管理功能，实现不同的应用和产品实时消费不同项目、不同类型的数据。...
成本可视化
通过可视化工具查看预算信息，累计的实际消费金额，以及每个滚动周期预实对比情况是在监控分析阶段必要的分析活动。预实走势报表可以展示累计实际值、累计实际值与预测值之和，按照月维度的增长趋势；本期预实报表可以展示本期实际值、本期...
功能特性
消费与投递 日志服务提供消费与投递功能，支持通过SDK、API实时消费数据；支持通过控制台将数据实时投递至OSS、MaxCompute等阿里云产品中。具体说明如下：支持通过Splunk、QRadar、Logstash、Flume等第三方软件消费数据。支持通过Java、...
功能发布记录
2023年8月 功能模块 变更类型 新增功能概述 发布时间 相关文档 成本变动 新增 成本异动智能检测能力上线发布，支持自动化检测实例级别云上消费金额的异常变动（T+1)，客户可根据算法检测结果按需评估并治理云上异常消费。20230814 查看成本...
查看消费者状态
单元化说明 在 LDC 单元化架构环境下，可以自由切换单元查看消费者状态，如下图所示。查看 Group ID 下单个消费者信息 如该 Group ID 的在线状态为 在线，则在 连接信息 页面您可以查看此时在线的每个消费者实例的具体信息，包括客户端 ID...
消费-搭建监控系统
结构化的数据：所有数据格式化成日志服务的数据模型，方便下游消费。弹性的服务能力：处理大规模数据写入和读取的能力。图 1.监控系统架构 如何搭建监控系统 收集监控数据 配置SLS的日志收集，确保日志收集到了日志服务。中间件使用API消费...
消费重试
消费失败的原因不会导致连续性，即当前消息消费失败是一个小概率事件，不是常态化的失败，后面的消息大概率会消费成功。此时可以对当前消息进行重试，避免进程阻塞。以下场景不建议使用消息重试 消费处理逻辑中使用消费失败来做条件判断的...
消息堆积和延迟问题
消费逻辑中的复杂耗时的操作是否可以做异步化处理，如果可以是否会造成逻辑错乱（消费完成但异步操作未完成）。设置消息的消费并发度 逐步调大线程的单个节点的线程数，并观测节点的系统指标，得到单个节点最优的消费线程数和消息吞吐量。...
消息队列 RocketMQ 客户端流控设计
限流方式有两种：针对消息订阅者的并发流控 针对消息订阅者的消费延时流控 针对消息订阅者的消费延时流控的基本原理是，每次消费时在客户端增加一个延时来控制消费速度，此时理论上消费并发最快速度为：MaxRate=1/ConsumInterval*...
普通消息
普通消息生命周期 初始化 消息被生产者构建并完成初始化，待发送到服务端的状态。待消费 消息被发送到服务端，对消费者可见，等待消费者消费的状态。消费中 消息被消费者获取，并按照消费者本地的业务逻辑进行处理的过程。此时服务端会等待...
基本概念
重置消费位点 以时间轴为坐标，在消息持久化存储的时间范围内（默认3天），重新设置Consumer对已订阅的Topic的消费进度，设置完成后Consumer将接收设定时间点之后由Producer发送到 云消息队列 RocketMQ 版 服务端的消息。更多信息，请参见 ...
查询消息轨迹
云消息队列 RocketMQ 版 将消息发送、消息存储、消息消费这几个关键节点的数据定义为轨迹参数，例如消息发送结果、发送耗时、消息到达服务端的时间、消息的消费结果、消费耗时、客户端信息等，并支持可视化查询。当消息收发结果不符合预期...
什么是Quick BI
Quick BI是一款全场景数据消费式的BI平台，秉承 全场景消费数据，让业务决策触手可及 的使命，通过智能的数据分析和可视化能力帮助企业构建数据分析系统，您可以使用Quick BI制作漂亮的仪表板、格式复杂的电子表格、酷炫的大屏、有分析思路...
注意要点
如果是发送消息被限流，建议关闭旧的连接，重新创建并初始化Channel，这样可以保证业务的连续性。消费消息 消费数据时，需要防止消费倾斜。具体做法，请参见 Connection和Channel的使用建议。消费消息时，请根据业务自身消费能力设置QoS，...
领域模型概述
订阅关系以消费组粒度进行管理，消费组通过定义订阅关系控制指定消费组下的消费者如何实现消息过滤、消费重试及消费进度恢复等。云消息队列 RocketMQ 版 的订阅关系除过滤表达式之外都是持久化的，即服务端重启或请求断开，订阅关系依然...
产品架构
消费与投递：日志服务支持数据实时消费，适用于Storm消费、Flume消费、Flink消费等场景；支持数据实时投递，适用于将数据投递至OSS、TSDB等云产品。更多信息，请参见 投递概述 和 消费概述。日志审计：日志服务支持实时自动化、中心化采集...
消息（Message）
生产者将业务数据的负载和拓展属性包装成消息发送到 云消息队列 RocketMQ 版 服务端，服务端按照相关语义将消息投递到消费端进行消费。云消息队列 RocketMQ 版 的消息模型具备如下特点：消息不可变性 消息本质上是已经产生并确定的事件，...
- 产品推荐
- 这些文档可能帮助您