数据订阅SDK容灾__最佳实践_数据传输-阿里云
为了简化用户使用SDK的复杂度,DTS实现了SDK容灾机制。这个机制依赖于SDK消费数据时,向DTS中控节点实时汇报消费时间点。本小节简单介绍如何使用DTS提供的SDK容灾机制。
要求
- SDK消费代码中,每消费一个message要调用一次ackAsConsumed,向DTS汇报消费时间点。
- 同一个订阅通道至少启动2个SDK下游互为主备。
消费架构图
DTS的一个订阅通道只能有一个SDK拉取到增量数据。如果在一个订阅通道中接多个SDK下游,那么只有其中一个订阅SDK能够接收到增量数据。根据这个原理,可以搭建SDK灾备架构。
在上图这个示例架构中,对一个订阅通道中,接了两个SDK消费下游,这两个SDK互为主备,同一个时间内,只有主SDK能订阅并消费到增量数据。当主SDK异常或是出现网络连接异常时,DTS会自动failover漂移到备SDK上,同时使用最后消费的时间点启动备SDK。主SDK每消费一条数据,会向DTS控制系统汇报一个ACK,即向控制系统汇报消费时间点。
最后更新:2016-11-23 16:03:55
上一篇:
触发器存在情况下如何配置同步作业__最佳实践_数据传输-阿里云
下一篇:
缓存更新策略__最佳实践_数据传输-阿里云
删除键__数据管理_DMS for Redis_用户指南(NoSQL)_数据管理-阿里云
更新编排模板__镜像与模板管理_用户指南_容器服务-阿里云
存储包购买流程__购买指导_文件存储-阿里云
安全组设置__ECS设置_操作指南_高性能计算-阿里云
阿里云胡晓明:服务100万家客户不算什么,服务1000万家才是能力
FTP上传经常中断__故障处理_云服务器 ECS-阿里云
API一览__API参考_E-MapReduce-阿里云
修改RDS实例访问模式__实例管理_API 参考_云数据库 RDS 版-阿里云
FailReason__数据类型_API参考_E-MapReduce-阿里云
渐进显示__格式转换_图片处理指南_对象存储 OSS-阿里云
相关内容
常见错误说明__附录_大数据计算服务-阿里云
发送短信接口__API使用手册_短信服务-阿里云
接口文档__Android_安全组件教程_移动安全-阿里云
运营商错误码(联通)__常见问题_短信服务-阿里云
设置短信模板__使用手册_短信服务-阿里云
OSS 权限问题及排查__常见错误及排除_最佳实践_对象存储 OSS-阿里云
消息通知__操作指南_批量计算-阿里云
设备端快速接入(MQTT)__快速开始_阿里云物联网套件-阿里云
查询API调用流量数据__API管理相关接口_API_API 网关-阿里云
使用STS访问__JavaScript-SDK_SDK 参考_对象存储 OSS-阿里云