数据订阅功能可以帮助您获取数据库的实时增量数据,适用于缓存更新策略、业务异步解耦、异构数据源的数据实时同步和复杂ETL的数据实时同步等多种业务场景。本文介绍数据订阅功能的具体使用流程,帮助您快速掌握创建、监控、管理数据订阅通道及消费数据的操作。 背景知识订阅方案概览介绍数据订阅功能支持的数据库和支持订阅的数据类型。功能特性 详情请参见数据订阅(新版)。数据订阅使用流程通常,使用数据传输服务DTS(Data Transmission Service)执行数据订阅的操作,您需要经历如下步骤。操作流程适用的订阅版本说明1.准备工作概览新版在使用DTS执行数据订阅前,您需要对源数据库做一些准备工作,以满足DTS对环境的要求。2.配置订阅任务新版您只需在控制台上进行简单操作,即可完成数据订阅的配置。3.管理订阅通道新版新增消费组配置完数据订阅通道后,您需要新增一个消费组供客户端进行数据消费。您也可以通过创建多个消费组,对同一个数据源的数据进行重复消费,从而降低数据订阅的使用成本,提升数据消费速度。可选:管理消费组对数据订阅通道的消费组进行管理(例如修改消费组密码、删除消费组)。可选:修改订阅对象在数据订阅的过程中,您可以修改订阅对象。4.消费订阅数据新版根据消费客户端和数据库的类型,选择订阅数据的消费方式:使用SDK示例代码消费订阅数据使用SDK示例代码消费PolarDB-X 1.0订阅数据使用flink-dts-connector消费订阅数据使用Kafka客户端消费订阅数据5.结束数据订阅新版释放实例即可结束数据订阅。 按量付费:详情请参见释放实例。包年包月:无法手动释放,到期7天后不续费将会自动被释放。 说明 您也可以通过初始化数据订阅通道来停止数据订阅,详情请参见重新配置数据订阅。