DataWorks為您提供的即時資料同步功能,方便您使用單表或整庫同步方式,將源端資料庫中部分或全部表的資料變化即時同步至目標資料庫中,實現目標庫即時保持和源庫的資料對應。
核心能力
即時同步支援的能力如下圖所示:
能力 | 描述 |
多種資料來源間的資料同步 | 即時同步支援多種資料來源,您可以將多種輸入及輸出資料來源搭配組成同步鏈路進行資料同步。詳情請參見支援的資料來源及同步方案。 |
複雜網路環境下的資料同步 | 即時同步支援阿里雲雲資料庫,本地IDC、ECS自建資料庫或非阿里雲資料庫等環境下的資料同步。配置前需確保資源群組與源端/目的端的網路連通性,配置詳情請參見:網路連通方案。 |
同步情境 | 即時同步支援單表即時資料同步至目標端單表、分庫分表即時增量資料同步至目標端單表。
|
即時同步任務配置 | 即時同步任務配置時支援的能力如下,您無需編寫代碼,通過簡單的任務配置即可實現單表ETL即時資料的收集。詳情請參見:配置單表即時同步任務,分庫分表同步至MaxCompute。 單表即時同步:
分庫分表即時同步:
|
即時同步任務營運 | 支援對同步任務設定監控警示
|
即時同步不支援在資料開發介面運行任務,您需要儲存、提交即時同步節點後,在生產環境營運中心運行該節點。
即時同步任務不支援同步視圖。
支援的資料來源
資料開發和Data Integration支援的資料來源有部分重疊,如您需要使用的類型在Data Integration側已支援,更推薦在Data Integration側建立即時同步任務。
Data Integration側支援的資料來源的源端和目的端並非任意組合,具體支援類型見配置來源和去向資料來源時的支援的同步類型。
資料開發
源端:MySQL、DataHub、LogHub、Kafka、PolarDB。
目的端:MaxCompute、Hologres、AnalyticDB MySQL 3.0、Elasticsearch、DataHub、Kafka。
資料處理:資料過濾、字串替換、資料脫敏。
Data Integration
源端:Kafka、Hologres、Oracle、LogHub、DataHub。
目的端:ApsaraDB for OceanBase、Data Lake Formation(DLF)、Doris、Hologres、MaxCompute、OSS、OSS-HDFS、StarRocks、Tablestore、Lindorm。
資料處理:資料過濾、字串替換、資料脫敏、JSON解析、欄位編輯與賦值。
開始使用
建立單表即時同步任務,請參見:DataStudio側即時同步任務配置、Data Integration側即時同步任務配置。
建立分庫分表即時同步任務,請參見:分庫分表同步至MaxCompute。
常見問題
即時同步任務常見問題請參見即時同步常見問題。