新增消费组
一个消费组只能创建一个消费者（consumer），并通过该消费者执行数据消费。若DTS增量数据采集模块或者客户端切换，则可能会导致数据重复。操作步骤 登录 数据传输控制台。在左侧导航栏，单击 数据订阅。在 数据订阅列表 页面上方，选择订阅...
队列服务订阅推送
在不同的消费者组间，数据会并列地推送给每一个存在的消费者，举例来看：如果您的多个消费者在同一个组内，您可以观察到数据会在这些消费者之间进行均衡地分发，消费者会收到不同的数据。如果您的多个消费者在多个不同的组内，您可以观察到...
新增消费组
一个消费组只能创建一个消费者（consumer），并通过该消费者执行数据消费。若DTS增量数据采集模块或者客户端切换，则可能会导致数据重复。操作步骤 进入订阅任务的列表页面。登录 DMS数据管理服务。在顶部菜单栏中，单击 集成与开发（DTS）...
用户洞察概述
品牌数据银行、达摩盘、Kafka推送：支持将企业的一方标签数据、AIPL模型、受众人群推送到 数据银行，支持将受众人群推送到 达摩盘、阿里云Kafka 或开源Kafka，进而实现线上线下融合消费者分析和线上二次触达，为企业品牌全域消费者运营提能...
通过Pull模式创建数据订阅通道
本文介绍通过Pull模式创建数据订阅功能，创建后订阅通道会实时拉取数据库实例的增量数据，并将增量数据保存在订阅通道中，您可以使用Lindorm提供的SDK从订阅通道中订阅增量数据并进行消费。...} } 说明 数据消费格式说明请参见 数据消费格式。
Kafka数据源
offset Long timestamp Long headers String partition Long 离线写数据 DataWorks将数据写入Kafka时，支持写入JSON格式或text格式的数据，不同的数据同步方案往Kafka数据源中写入数据时，对数据的处理策略不一致，详情如下。重要 写入text...
Kafka数据迁移MaxCompute最佳实践
kafka-console-producer.sh-broker-list emr-header-1:9092-topic testkafka 您可以同时再打开一个SSH窗口，执行如下命令，模拟消费者验证数据是否已成功写入Kafka。当数据写入成功时，您可以看到已写入的数据。kafka-console-consumer.sh-...
通过RAM角色授权模式配置数据源
场景示例：如上文待扮演角色的场景示例所述，当云账号管理者为大数据团队定义了 BigDataOssRole 角色后，需要指定仅相关人员才能使用该角色。您可以自定义Policy为 BigDataOssRoleAllowUse，并授权给相关人员。创建名称为 ...
数据集概述
在数据源模块中配置好所需数据源后，基于产品内置的消费者运营模型，您可以完成企业一方用户标签数据集、行为数据集等的创建，为后续的洞察圈选、营销投放功能提供数据基础。支持创建以下数据集：用户标签数据集：基于用户标签大宽表构建...
实时精准营销（人群圈选）
总结 RDS PostgreSQL 12或以上版本支持位图功能（roaringbitmap插件），可以高效生成、压缩、解析位图数据，支持最常见的位图聚合操作（与、或、非、异或），满足您在亿级以上用户、千万级标签的大数据量下实时精准营销、快速圈选用户的...
用户洞察概述
随着互联网技术的发展，企业通过各种途径积累了消费者资产，Quick Audience用户洞察模块旨在通过丰富的用户洞察模型和便捷的策略配置，帮助企业完成消费者多维洞察分析，为后续的消费者运营和触达奠定人群基础。功能简介 用户洞察模块提供...
什么是Quick Audience
Quick Audience为您打造一站式的消费者资产管理和运营平台，通过快速的数据对接、方便的模型配置、灵活的圈选完成用户的洞察和分群，通过多渠道的链接、自动化营销链路的编排，完成用户的触达和营销策略的沉淀，提升企业消费者运营的效率，...
同步 OceanBase 数据库的数据至 RocketMQ
是否允许消息追踪 如果允许消息追踪，则可以追踪到一条消息从生产者发送到消息队列 RocketMQ 版服务端，再到消费者消费处理，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整项目信息。该消息轨迹可以作为生产环境中排查问题强...
客户案例
通过“先鉴别，后发货”的服务模式，为用户打造透明、健康、安全的文化消费环境，让普通消费者敢于购买国风好物，感受国风文化的魅力。客户诉求 随着电商业务的快速发展，期望能采用云平台提供的SaaS、PaaS服务搭建研发系统，助力提升开发...
API概览
UpdateGatewayAuthConsumerResourceStatus 更新网关鉴权消费者的授权状态 更新网关鉴权消费者的授权状态。DeleteGatewayAuthConsumer 删除网关鉴权消费者 删除网关鉴权消费者。GetGatewayAuthConsumerDetail 获取网关鉴权消费者细节 获取...
逻辑解码概念
每一个槽有自己的状态，允许不同的消费者从该数据库的更改流中的不同点开始接收更改。对于大多数应用，每一个消费者都将要求一个单独的槽。逻辑复制槽完全不知道接收者的状态。甚至可能会有多个不同的接收者在不同时间使用同一个槽，它们将...
专题广场
专题广场概述 通过资产专题，您可以打造面向主题的精品数据资产管理和消费生态，帮助数据生产者和消费者实现高效协作。此外，您还可以设置精选专题，精选专题常用于管理质量较高、可直接消费的核心资产。权限说明 每个用户可在专题广场查看...
专题广场
专题广场概述 通过资产专题，您可以打造面向主题的精品数据资产管理和消费生态，帮助数据生产者和消费者实现高效协作。此外，您还可以设置精选专题，精选专题常用于管理质量较高、可直接消费的核心资产。权限说明 每个用户可在专题广场查看...
创建行为偏好标签
Dataphin标签支持通过可视化方式配置偏好规则，将行为数据加工偏好结果作为标签值。如基于消费者最近7天浏览行为，加工浏览商品偏好标签。本文将指导您如何通过行为偏好创建离线标签。前提条件 创建行为偏好标签前需先创建对应的行为关系。...
基本概念
数据资产：数据资源平台中存在大量的数据表、标签、API等各类数据资产，数据管理者通过数据汇聚、数据治理、数据分析后，需要对整个平台数据进行统一管控，了解平台的核心数据资产，提供对应的数据资产管理规范。统一服务 应用：是调用API...
基本概念（V4）
支持自定义以下标签：偏好类标签：基于 用户行为表、订单明细表 数据，将用户出现次数最多或数值最大的维度特征作为标签值。例如：用户偏好的购物时段/价格区间/渠道/主题/品类、用户购买的最高单品价格。忠诚度标签：基于 用户行为表、...
使用SDK示例代码消费订阅数据
订阅通道的 数据消费 界面。如您在 consumerContext.java 文件中 setUserRegisteredStore(newUserMetaStore())配置了外部的持久化共享存储介质（如数据库），该存储介质每5秒会保存一次消息位点，供您查询。首次启动SDK客户端，需传入消费...
使用SDK示例代码消费订阅数据
订阅通道的 数据消费 界面。如您在 consumerContext.java 文件中 setUserRegisteredStore(new UserMetaStore())配置了外部的持久化共享存储介质（如数据库），该存储介质每5秒会保存一次消息位点，供您查询。首次启动SDK客户端，需传入消费...
API概览
ConsumerGroupHeartBeat 消费者发送心跳到服务端 消费者发送心跳到服务端。ListConsumerGroup 查询消费组 调用ListConsumerGroup接口查询指定Logstore的所有消费组。GetCheckPoint 获取指定消费组的消费点 调用GetCheckPoint接口获取指定...
如何对JSON类型进行高效分析
因此，数据仓库往往需要同时维护ETL作业逻辑和业务表结构，而频繁发布ETL作业常常会影响上游数据消费和下游结果入仓，且在不支持INSTANT DDL时修改大表结构代价相对比较高，容易影响正常查询业务。总体来说，传统数仓解决方案虽然能够提供...
大数据专家服务
大数据专家服务（Bigdata Expert Service）是由阿里云大数据专家基于阿里云多年大数据架构、应用、运维、AI算法建模等最佳实践经验及方法论为用户提供全方位的大数据产品技术、咨询服务及售后专家服务运维保障，帮助用户构建和持续优化的大...
Hologres物理表和字段详情
⑥ 使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
Hologres物理表和字段详情
⑥ 使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
MaxCompute物理表和字段详情
⑥使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表类型...
MaxCompute物理表和字段详情
⑥使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表类型...
AnalyticDB for PostgreSQL物理表和字段详情
⑥ 使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
星环ArgoDB/TDH Inceptor物理表和字段详情
⑥ 使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
CDH/EMR/亚信/FI/CDP物理表和字段详情
⑥ 使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
逻辑表和字段资产详情
⑥ 使用说明 您可以为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
逻辑表和字段资产详情
⑥ 使用说明 您可以为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
动态过滤器（Dynamic Filter）
DFC（Dynamic Filter Consumer）算子：动态过滤器的消费者（Consumer），利用Bloom Filter和Range Filter过滤大表侧的数据。Range Filter会尽可能将过滤条件下推到底层存储，以便从源头过滤数据。对于不同类型的JOIN语义，JOIN对象可担任的...
动态过滤器（Dynamic Filter）
DFC（Dynamic Filter Consumer）算子：动态过滤器的消费者（Consumer），利用Bloom Filter和Range Filter过滤大表侧的数据。Range Filter会尽可能将过滤条件下推到底层存储，以便从源头过滤数据。对于不同类型的JOIN语义，JOIN对象可担任的...
StarRocks物理表和字段详情
⑥ 使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑦ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
物化视图和字段资产详情
⑤ 使用说明 您可为数据表添加使用说明，为数据浏览者和消费者提供信息参考。单击 新增使用说明 进行添加。⑥ 资产信息 为您展示物理表的 基础信息、物理信息、使用信息 和 变更信息 等详细信息。基础信息：包括环境、专题目录、项目、表...
项目管理（新版）
创建项目 MaxCompute控制台创建的Project允许被各客户端使用，DataWorks提供统一的全链路大数据开发治理平台，紧密的集成MaxCompute，其工作空间标准模式不支持绑定存量MaxCompute项目。推荐您直接通过DataWorks创建MaxCompute项目并进行...
- 产品推荐
- 这些文档可能帮助您