配置数据订阅任务
数据订阅功能可以帮助您获取数据库的实时增量数据，您可以根据自身业务需求自由消费增量数据，并写入任意目标端，适配各类业务场景，例如缓存更新、业务异步解耦、异构数据源数据实时同步及含复杂ETL的多种业务场景。本文将介绍在DTS专属...
【通知】2021年12月1日起新创建的DTS订阅任务的网络...
2021年12月1日起，新创建的DTS订阅任务限制了网络类型，源实例不支持为经典网络的云数据库，或部署在ECS经典网络中，并且下游消费客户端必须通过专有网络消费订阅数据。说明 对于2021年12月1日前已创建的DTS订阅任务，此次功能变更不会影响...
超大消息传输
当消息内容大于64 KB以至于无法直接存入MNS队列时，不做...注意事项 大消息主要消费网络带宽，用该方案发送大消息时，生产者和消费者的网络带宽可能会是瓶颈。大消息网络传输时间较长，受网络波动影响的概率更大，建议在上层做必要的重试。
创建DMS逻辑库的数据订阅任务
本文介绍如何创建数据管理DMS（Data Management）逻辑库的数据订阅任务。...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费PolarDB-X 1.0订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建RDS MySQL数据订阅任务
通过数据订阅功能，您可以实时订阅源库的增量数据，轻松帮助业务实现轻量级缓存更新、业务...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建PolarDB MySQL版数据订阅任务
通过数据订阅功能，您可以实时订阅增量数据，轻松帮助业务实现轻量级缓存更新、业务异步解耦...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建PolarDB-X 1.0数据订阅任务
本文介绍如何创建 PolarDB-X 1.0 数据订阅任务。前提条件 已创建 PolarDB-X 1.0...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费PolarDB-X 1.0订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建PolarDB-X 2.0数据订阅任务
本文介绍如何创建 PolarDB分布式版 数据订阅任务。前提条件 已创建 PolarDB分布式版 实例和...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建PolarDB PostgreSQL版数据订阅任务
本文为您介绍如何创建 PolarDB PostgreSQL版 数据订阅任务。前提条件 已创建源 PolarDB ...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
使用DTS创建数据订阅
DTS支持创建自建PosgreSQL、RDS PostgreSQL 数据订阅任务。本文以 RDS PostgreSQL 为例介绍...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建RDS PostgreSQL数据订阅任务
DTS支持创建自建PosgreSQL、RDS PostgreSQL 数据订阅任务。本文以 RDS PostgreSQL 为例介绍...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建PolarDB PostgreSQL版（兼容Oracle）数据订阅任务
本文为您介绍如何创建 PolarDB PostgreSQL版（兼容Oracle）数据订阅任务。...根据消费客户端类型，选择订阅数据的消费方式：使用SDK示例代码消费订阅数据 使用flink-dts-connector消费订阅数据 使用Kafka客户端消费订阅数据
创建Oracle数据订阅任务
如自建Oracle为RAC架构，且用专线/VPN网关/智能接入网关、数据库网关DG、云企业网CEN和ECS的接入方式，则不支持配置ScanIP，仅支持将其中任意1个VIP配置到连接信息中，该方式配置后不支持RAC的节点切换。待订阅的表需具备主键或唯一约束，...
为什么实时消费的速率未达到Shard的读写阈值上限？
实时消费的速率未达到Shard的读写阈值上限的可能原因如下：您所设置的加工规则逻辑较为复杂。通过数据加工进行跨地域传输数据时，依赖公网网络环境，可能因为公网网络问题影响消费速率。
账单查询
在 账单详情 页面，根据需要单击相应的页签，查看私网连接的消费情况。账单流水 页签：可查看在阿里云上的消费账单流水信息，包括每一笔预付费的订单和每一笔后付费账单。明细账单 页签：可通过明细账单，查看在阿里云上的消费信息，如商品...
消费端从服务端拉取不到消息或拉取消息缓慢
问题现象 Topic中有消息并且Consumer未消费到最新的位置，出现消费端从服务端拉取不到消息或拉取消息缓慢的情况（特别是公网消费时）。可能原因 可能的原因包括：消费流量达到网络带宽。单个消息大小超过网络带宽。Consumer每次拉取的消息...
账单查询
您可以在用户中心查看ECS实例相关的费用账单和消费明细，以了解消费情况。背景信息 阿里云提供延期免停权益，即当按量付费的资源发生欠费后，提供一定额度或时长继续使用云服务的权益，延停期间正常计费。具体使用说明和规则，请参见 延期...
收发顺序消息
顺序消息（FIFO消息）是 云消息队列 RocketMQ 版 提供的一种严格按照顺序来发布和消费的消息类型。本文提供使用HTTP协议下的Go SDK收发顺序消息的示例代码。背景信息 顺序消息分为两类：全局顺序：对于指定的一个Topic，所有消息按照严格的...
按量付费云资源账单结算策略调整及计费精度提升
用户中心控制台>账单>月账单概览>消费趋势>消费合计>官网价 跳转至 账单流水 跳转至 用户中心控制台>账单>账单详情>账单明细 用户中心控制台>账单>月账单概览>消费趋势>消费合计>应付金额 跳转至 账单流水 跳转至 用户中心控制台>账单>账单...
收发定时消息和延时消息
背景信息 延时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端，但并不期望立马投递这条消息，而是延迟一定时间后才投递到Consumer进行消费，该消息即延时消息。定时消息：Producer将消息发送到 云消息队列 RocketMQ 版 服务端...
收发普通消息
d,NextConsumeTime:%d"+"\tBody:%s"+"\tProps:%s",v.MessageId,v.PublishTime,v.MessageTag,v.ConsumedTimes,v.FirstConsumeTime,v.NextConsumeTime,v.MessageBody,v.Properties)}/NextConsumeTime前若不确认消息消费成功，则消息会被重复...
收发事务消息
d,NextConsumeTime:%d"+"\tBody:%s"+"\tProps:%s",v.MessageId,v.PublishTime,v.MessageTag,v.ConsumedTimes,v.FirstConsumeTime,v.NextConsumeTime,v.MessageBody,v.Properties)}/NextConsumeTime前若不确认消息消费成功，则消息会被重复...
使用限制
失败推送重试策略 由于消费客户端离线、消息消费慢等原因，消息不能实时消费，而进入堆积队列。消费客户端重新上线并恢复稳定消费能力后，物联网平台重试推送堆积消息。如果客户端对重试推送的消息消费失败，可能导致堆积队列阻塞。按大约...
云效赋能一站式企业消费管理领先品牌「差旅壹号」持续...
背景 差旅壹号作为一站式企业消费管理平台的领先品牌，涵盖了一站式企业商旅管理、一站式企业出行管理、一站式企业用餐管理、一站式企业福利管理平台。是为了全面实现“一站式全员自助预订、费用智能化管控、企业集中采购、费用企业统一...
发票常见问题
可以的，请提交电子发票退票申请，待电子发票冲红后。您可重新申请纸质发票。电子发票退票除提交线上退票申请外，需要线下邮寄拒收证明吗？不需要，您在提交线上退票申请时需要您备注退票原因，无需再线下邮寄拒收证明。电子发票是否可以...
作废发票、申请退票
发票状态显示“已作废/已红冲”时，您可以收到发票作废或冲红短信提醒后重新提交新的发票申请。5 错误发票您已经接收，但未入账/未抵扣 请将错误发票邮寄回我司，并完成退票后，再重新申请发票，操作步骤如下：请您将原错误发票通过快递...
使用SDK示例代码消费PolarDB-X 1.0订阅数据
本文介绍通过SDK示例代码消费分布式订阅数据，支持的数据源包括PolarDB-X 1.0和DMS LogicDB。前提条件 已安装JDK 1.8版本。已安装IntelliJ IDEA软件。注意事项 如果使用子账号（RAM用户）来订阅数据，该账号需具备 AliyunDTSFullAccess ...
阿里云日志服务Splunk Add-on
一个消费组由多个消费者构成，同一个消费组下面的消费者共同消费一个Logstore中的数据，消费者之间不会重复消费数据。一个Logstore下面会有多个Shard。每个Shard只会分配到一个消费者。一个消费者可以同时拥有多个Shard。所创建的消费者...
创建SLS Sink Connector
使用已有 并发配额（消费者数）消费Topic数据的并发线程数，线程和Topic分区的对应关系如下：Topic分区数=并发消费数：一个线程消费一个Topic分区。建议使用。Topic分区数>并发消费数：多个并发消费会均摊所有分区消费。Topic分区数<并发...
创建Elasticsearch Sink Connector
更多信息，请参见 配置实例公网或私网访问白名单。步骤二：创建Elasticsearch Sink Connector 登录 云消息队列 Kafka 版 控制台，在 概览 页面的 资源分布 区域，选择地域。在左侧导航栏，选择 Connector生态集成>消息流出（Sink）。在 ...
创建OSS Sink Connector（旧版）
使用已有 并发配额（消费者数）消费Topic数据的并发线程数，线程和Topic分区的对应关系如下：Topic分区数=并发消费数：一个线程消费一个Topic分区。建议使用。Topic分区数>并发消费数：多个并发消费会均摊所有分区消费。Topic分区数<并发...
客户报备流程操作指引
当客户与合作伙伴产生关联后，客户的消费才会以对应的方式计入合作伙伴业绩。通过不同的关联方式，阿里云代理伙伴可以与客户形成“账号关联关系”或者“商机关联关系”。本文将详细介绍代理伙伴如何通过报备客户的方式与客户形成“账号关联...
创建AnalyticDB Sink Connector
使用已有 并发配额（消费者数）消费Topic数据的并发线程数，线程和Topic分区的对应关系如下：Topic分区数=并发消费数：一个线程消费一个Topic分区。建议使用。Topic分区数>并发消费数：多个并发消费会均摊所有分区消费。Topic分区数<并发...
创建MaxCompute Sink Connector
使用已有 并发配额（消费者数）消费Topic数据的并发线程数，线程和Topic分区的对应关系如下：Topic分区数=并发消费数：一个线程消费一个Topic分区。建议使用。Topic分区数>并发消费数：多个并发消费会均摊所有分区消费。Topic分区数<并发...
云消息队列 Kafka 版
请使用独立的消费组来创建事件源，不要和已有的业务混用消费组，以免影响已有的消息收发。GID_http_1 并发配额（消费者数）选择源实例的消费者数。1 消费位点 选择开始消费消息的位点。最新位点：从最新位点开始消费。最早位点：从最初位点...
自定义事件源消息队列Kafka版
1 消费位点 开始消费的位置。最新位点：从最新位点开始消费。最早位点：从最初位点开始消费。最新位点 网络配置 事件总线EventBridge 集成 消息队列Kafka版 数据时支持的网络连接方式。默认网络 自建公网 默认网络 专有网络VPC 选择VPC ID...
Kafka触发器
2 消费位点 选择消息的消费位点，即 消息队列 Kafka 版 从事件总线开始拉取消息的位置。取值说明如下。最早位点：从最早位点开始消费。最新位点：从最新位点开始消费。最新位点 网络配置 选择路由消息的网络类型。取值说明如下。默认网络：...
EventBridge事件调度
test-Project 日志库 选择创建的日志服务SLS的Logstore test-LogStore 起始消费位点 起始消费位点，可以选择最早或最新位点，也可以从指定时间开始消费。最新位点 角色配置 授权事件总线EventBridge使用此角色读取SLS日志内容。testRole ...
精灵贴使用
精灵贴包含了设备配网二维码与设备配网帮助，可以帮助消费者便捷高效地了解设备配网信息，并快速激活设备。使用天猫精灵生态的产品都必须在产品包装上粘贴精灵贴。精灵贴使用说明 配置配网引导的连接文案。配置完成后，系统将会自动生成...
消费者负载均衡
消费者从 云消息队列 RocketMQ 版 获取消息消费时，通过消费者负载均衡策略，可将主题内的消息分配给指定消费者分组中的多个消费者共同分担，提高消费并发能力和消费者的水平扩展能力。本文介绍 云消息队列 RocketMQ 版 消费者的负载均衡...
- 产品推荐
- 这些文档可能帮助您