日本熟妇hd丰满老熟妇,中文字幕一区二区三区在线不卡 ,亚洲成片在线观看,免费女同在线一区二区

RDS MySQL同步至ClickHouse集群

重要

本文中含有需要您注意的重要提示信息,忽略該信息可能對您的業務造成影響,請務必仔細閱讀。

云數據庫ClickHouse是面向聯機分析處理的列式數據庫,基于大寬表的聚合分析查詢性能非常優異,比其他分析型數據庫速度快一個數量級,通過數據傳輸服務DTS(Data Transmission Service),您可以將MySQL數據庫(例如自建MySQL或RDS MySQL)同步至ClickHouse集群,幫助您輕松實現數據的流轉,將企業數據集中分析。本文以RDS MySQL實例為例,介紹從RDS MySQL同步至ClickHouse集群的配置步驟。

前提條件

  • 已創建20.8及以上版本的目標ClickHouse集群,詳情請參見新建集群

    說明

    ClickHouse集群的存儲空間需大于源RDS MySQL實例已使用的存儲空間。

  • 已在目標ClickHouse集群創建用于接收數據的數據庫,詳情請參見創建數據庫。

    重要

    建議ClickHouse集群中創建的數據庫名稱與源RDS MySQL實例待同步數據所屬的數據庫名稱一致,否則您需要在配置任務對象及高級配置階段,在已選擇對象框中使用庫名映射功能。設置方式,請參見庫表列名映射。

注意事項

類型

說明

源庫限制

  • 待同步對象不支持無主鍵的表。

  • 如同步對象為表級別,且需進行編輯(如表列名映射),則單次同步任務僅支持同步至多1000張表。當超出數量限制,任務提交后會顯示請求報錯,此時建議您拆分待同步的表,分批配置多個任務,或者配置整庫的同步任務。

  • Binlog日志:

    • RDS MySQL默認已開啟Binlog,您需確保binlog_row_image的值為full,否則預檢查階段提示報錯,且無法成功啟動數據同步任務。參數設置方法,請參見設置實例參數

      重要
      • 若源實例為自建MySQL,則需開啟Binlog,并且設置binlog_format為row且binlog_row_image為full。

      • 若源實例自建MySQL是雙主集群(兩者互為主從),為保障DTS能獲取全部的Binlog日志,則您需開啟參數log_slave_updates。具體操作請參見為自建MySQL創建賬號并設置binlog

    • DTS要求源數據庫的本地Binlog日志至少保留7天以上,否則DTS可能因無法獲取Binlog而導致任務失敗,極端情況下甚至可能會導致數據不一致或丟失。由于您所設置的Binlog日志保存時間低于DTS要求的時間進而導致的問題,不在DTS的SLA保障范圍內。如源為RDS MySQL,具體操作請參見管理本地日志(Binlog)

  • 在庫表結構同步和全量同步階段,請勿執行庫或表結構變更的DDL操作,否則會導致數據同步任務失敗。

其他限制

  • 若源RDS MySQL的DDL語句不是標準的MySQL語法,則可能導致同步任務失敗或數據丟失。

  • 不支持同步RENAME TABLE的操作。

  • 云數據庫ClickHouse的時間類型數據存在范圍限制,若RDS MySQL中的時間不在該范圍內,會導致同步到云數據庫ClickHouse的時間不正確。范圍限制,請參見時間信息。

  • 分區鍵不可以選擇為可空的字段,否則同步任務將會失敗。

  • 待同步數據庫的數量符合云數據庫ClickHouse的限制,即不超過256個。

  • 待同步數據庫、表和列的名稱符合云數據庫ClickHouse的命名規范,相關規范請參見對象命名規范限制

  • 在庫表結構同步階段,DTS會在目標表中添加字段_sign(或is_deleted)和_version。若您配置同步類型時未勾選庫表結構同步,則需要手動在目標端創建接收數據的表,并在表中添加額外的字段。創建表的要求和字段信息,請參見表和字段信息

  • 執行數據同步前需評估源庫和目標庫的性能,同時建議業務低峰期執行數據同步。否則全量數據初始化時將占用源庫和目標庫一定的讀寫資源,可能會導致數據庫的負載上升。

  • 如同步對象為單個或多個表(非整庫),那么在數據同步時,勿對源庫的同步對象使用pt-online-schema-change等類似工具執行在線DDL變更,否則會導致同步失敗。

    您可以使用數據管理DMS(Data Management)來執行在線DDL變更,請參見不鎖表結構變更。

  • 在DTS同步期間,不允許有除DTS外的數據寫入目標庫,否則會導致源庫與目標庫數據不一致。

  • 若RDS MySQL實例已開通全密態(EncDB)功能,則不支持全量數據同步。

  • 若實例運行失敗,DTS技術支持人員將在8小時內嘗試恢復該實例。在恢復失敗實例的過程中,可能會對該實例進行重啟、調整參數等操作。

    說明

    在調整參數時,僅會修改實例的參數,不會對數據庫中的參數進行修改。可能修改的參數,包括但不限于修改實例參數中的參數。

其他注意事項

  • 當源庫為自建MySQL時:

    • 在同步時,如果源庫進行主備切換,將會導致同步任務失敗。

    • 由于DTS的延遲時間是根據同步到目標庫最后一條數據的時間戳和當前時間戳對比得出,源庫長時間未執行DML操作可能導致延遲信息不準確。如果任務顯示的延遲時間過大,您可以在源庫執行一個DML操作來更新延遲信息。

      說明

      如果同步對象選擇為整庫,您還可以創建心跳表,心跳表每秒定期更新或者寫入數據。

    • DTS會在源庫定時執行CREATE DATABASE IF NOT EXISTS `test`命令以推進Binlog位點。

  • 當源庫為RDS MySQL時:

    不記錄事務日志的RDS MySQL實例(如RDS MySQL 5.6版本的只讀實例)不支持作為源庫。

費用說明

同步類型鏈路配置費用
庫表結構同步和全量數據同步不收費。
增量數據同步收費,詳情請參見計費概述

支持同步的SQL操作

操作類型

SQL操作語句

DML

INSERT、UPDATE、DELETE

DDL

  • CREATE TABLE

  • TRUNCATE TABLE

  • ALTER TABLE

  • ADD COLUMN

  • MODIFY COLUMN

  • DROP TABLE、DROP COLUMN

數據類型映射關系

由于MySQL和ClickHouse集群支持的數據類型不同,數據類型無法一一對應。所以DTS在進行結構初始化時,會根據目標庫支持的數據類型進行類型映射,詳情請參見結構初始化涉及的數據類型映射關系。

數據庫賬號的權限要求

數據庫

所需權限

創建及授權方式

RDS MySQL

待同步對象的讀權限。

創建賬號修改賬號權限。

目標ClickHouse集群

  • 22.8及以上版本:目標庫的讀寫權限,高權限賬號符合要求。

  • 21.8版本:讀寫和設置權限允許DDL。

社區兼容版賬號管理企業版賬號管理

說明

若您使用的源庫賬號不是通過RDS MySQL控制臺創建且授權,您需確保該賬號具備REPLICATION CLIENT、REPLICATION SLAVE、SHOW VIEW和SELECT權限。

操作步驟

  1. 進入同步任務的列表頁面。

    1. 登錄DMS數據管理服務。

    2. 在頂部菜單欄中,單擊集成與開發。

    3. 在左側導航欄,選擇數據傳輸(DTS) > 數據同步。

    說明
  2. 同步任務右側,選擇同步實例所屬地域。

    說明

    新版DTS同步任務列表頁面,需要在頁面左上角選擇同步實例所屬地域。

  3. 單擊創建任務,配置源庫及目標庫信息。

    類別

    配置

    說明

    任務名稱

    DTS會自動生成一個任務名稱,建議配置具有業務意義的名稱(無唯一性要求),便于后續識別。

    源庫信息

    選擇已有的DMS數據庫實例(可選,如未創建可忽略此處選擇,直接在下方配置數據庫信息即可)

    您可以按實際需求,選擇是否使用已有實例。

    • 如使用已有實例,下方數據庫信息將自動填入,您無需重復輸入。

    • 如不使用已有實例,您需要輸入下方的數據庫信息。

    數據庫類型

    選擇MySQL。

    接入方式

    選擇云實例。

    實例地區

    選擇源RDS MySQL實例所屬地域。

    是否跨阿里云賬號

    本示例為同一阿里云賬號間的同步,選擇不跨賬號。

    RDS實例ID

    選擇源RDS MySQL實例ID。

    數據庫賬號

    填入源RDS MySQL實例的數據庫賬號,權限要求請參見數據庫賬號的權限要求。

    數據庫密碼

    填入該數據庫賬號對應的密碼。

    連接方式

    根據需求選擇非加密連接SSL安全連接。如果設置為SSL安全連接,您需要提前開啟RDS MySQL實例的SSL加密功能,詳情請參見使用云端證書快速開啟SSL鏈路加密。

    目標庫信息

    選擇已有的DMS數據庫實例(可選,如未創建可忽略此處選擇,直接在下方配置數據庫信息即可)

    您可以按實際需求,選擇是否使用已有實例。

    • 如使用已有實例,下方數據庫信息將自動填入,您無需重復輸入。

    • 如不使用已有實例,您需要輸入下方的數據庫信息。

    數據庫類型

    選擇ClickHouse。

    接入方式

    選擇云實例

    實例地區

    選擇目標ClickHouse集群所屬地域。

    是否跨阿里云賬號

    本示例為同一阿里云賬號間的同步,選擇不跨賬號。

    集群類型

    請根據實際情況選擇ClickHouse集群的類型。

    集群ID

    選擇目標ClickHouse集群的ID。

    數據庫賬號

    填入目標ClickHouse集群的數據庫賬號,權限要求請參見數據庫賬號的權限要求

    數據庫密碼

    填入該數據庫賬號對應的密碼。

  4. 配置完成后,單擊頁面下方的測試連接以進行下一步

    如果源或目標數據庫是阿里云數據庫實例(例如RDS MySQL、云數據庫MongoDB版等),DTS會自動將對應地區DTS服務的IP地址添加到阿里云數據庫實例的白名單中;如果源或目標數據庫是ECS上的自建數據庫,DTS會自動將對應地區DTS服務的IP地址添加到ECS的安全規則中,您還需確保自建數據庫沒有限制ECS的訪問(若數據庫是集群部署在多個ECS實例,您需要手動將DTS服務對應地區的IP地址添到其余每個ECS的安全規則中);如果源或目標數據庫是IDC自建數據庫或其他云數據庫,則需要您手動添加對應地區DTS服務的IP地址,以允許來自DTS服務器的訪問。DTS服務的IP地址,請參見DTS服務器的IP地址段。

    警告

    DTS自動添加或您手動添加DTS服務的公網IP地址段可能會存在安全風險,一旦使用本產品代表您已理解和確認其中可能存在的安全風險,并且需要您做好基本的安全防護,包括但不限于加強賬號密碼強度防范、限制各網段開放的端口號、內部各API使用鑒權方式通信、定期檢查并限制不需要的網段,或者使用通過內網(專線/VPN網關/智能網關)的方式接入。

  5. 配置任務對象及高級配置。

    配置

    說明

    同步類型

    固定選中增量同步。默認情況下,您還需要同時選中庫表結構同步全量同步。預檢查完成后,DTS會將源實例中待同步對象的全量數據在目標集群中初始化,作為后續增量同步數據的基線數據。

    目標已存在表的處理模式

    • 預檢查并報錯攔截:檢查目標數據庫中是否有同名的表。如果目標數據庫中沒有同名的表,則通過該檢查項目;如果目標數據庫中有同名的表,則在預檢查階段提示錯誤,數據同步任務不會被啟動。

      說明

      如果目標庫中同名的表不方便刪除或重命名,您可以更改該表在目標庫中的名稱,請參見庫表列名映射。

    • 忽略報錯并繼續執行:跳過目標數據庫中是否有同名表的檢查項。

      警告

      選擇為忽略報錯并繼續執行,可能導致數據不一致,給業務帶來風險,例如:

      • 表結構一致的情況下,如在目標庫遇到與源庫主鍵或唯一鍵的值相同的記錄:

        • 全量期間,DTS會保留目標集群中的該條記錄,即源庫中的該條記錄不會同步至目標數據庫中。

        • 增量期間,DTS不會保留目標集群中的該條記錄,即源庫中的該條記錄會覆蓋至目標數據庫中。

      • 表結構不一致的情況下,可能會導致無法初始化數據、只能同步部分列的數據或同步失敗,請謹慎操作。

    目標庫對象名稱大小寫策略

    您可以配置目標實例中同步對象的庫名、表名和列名的英文大小寫策略。默認情況下選擇DTS默認策略,您也可以選擇與源庫、目標庫默認策略保持一致。更多信息,請參見目標庫對象名稱大小寫策略。

    源庫對象

    源庫對象框中單擊待同步對象,然后單擊向右將其移動至已選擇對象框。

    說明

    同步對象的選擇粒度為庫、表、列。

    已選擇對象

    • 如需更改單個同步對象在目標實例中的名稱,請右擊已選擇對象中的同步對象,設置方式,請參見庫表列名單個映射

    • 如需批量更改同步對象在目標實例中的名稱,請單擊已選擇對象方框右上方的批量編輯,設置方式,請參見庫表列名批量映射

    說明
    • 若您需設置條件過濾數據,請在已選擇對象中右擊待同步的表,在彈出的對話框中設置過濾條件。設置方法請參見設置過濾條件。

    • 如果使用了對象名映射功能(指定用于接收數據的庫數據庫或集合),可能會導致依賴這個對象的其他對象同步失敗。

  6. 單擊下一步高級配置,進行高級配置。

    配置

    說明

    選擇調度該任務的專屬集群

    DTS默認將任務調度到共享集群上,您無需選擇。若您希望任務更加穩定,可以購買專屬集群來運行DTS同步任務。更多信息,請參見什么是DTS專屬集群。

    設置告警

    是否設置告警,當同步失敗或延遲超過閾值后,將通知告警聯系人。

    源庫、目標庫無法連接后的重試時間

    在同步任務啟動后,若源庫或目標庫連接失敗則DTS會報錯,并會立即進行持續的重試連接,默認持續重試時間為720分鐘,您也可以在取值范圍(10~1440分鐘)內自定義重試時間,建議設置30分鐘以上。如果DTS在設置的重試時間內重新連接上源庫、目標庫,同步任務將自動恢復。否則,同步任務將會失敗。

    說明
    • 針對同源或者同目標的多個DTS實例,如DTS實例A和DTS實例B,設置網絡重試時間時A設置30分鐘,B設置60分鐘,則重試時間以低的30分鐘為準。

    • 由于連接重試期間,DTS將收取任務運行費用,建議您根據業務需要自定義重試時間,或者在源和目標庫實例釋放后盡快釋放DTS實例。

    源庫、目標庫出現其他問題后的重試時間

    在同步任務啟動后,若源庫或目標庫出現非連接性的其他問題(如DDL或DML執行異常),則DTS會報錯并會立即進行持續的重試操作,默認持續重試時間為10分鐘,您也可以在取值范圍(1~1440分鐘)內自定義重試時間,建議設置10分鐘以上。如果DTS在設置的重試時間內相關操作執行成功,同步任務將自動恢復。否則,同步任務將會失敗。

    重要

    源庫、目標庫出現其他問題后的重試時間的值需要小于源庫、目標庫無法連接后的重試時間的值。

    是否限制全量遷移速率

    在全量同步階段,DTS將占用源庫和目標庫一定的讀寫資源,可能會導致數據庫的負載上升。您可以根據實際情況,選擇是否對全量同步任務進行限速設置(設置每秒查詢源庫的速率QPS每秒全量遷移的行數RPS每秒全量遷移的數據量(MB)BPS),以緩解目標庫的壓力。

    說明

    僅當同步類型選擇了全量同步時才可以配置。

    是否限制增量同步速率

    您也可以根據實際情況,選擇是否對增量同步任務進行限速設置(設置每秒增量同步的行數RPS每秒增量同步的數據量(MB)BPS),以緩解目標庫的壓力。

    環境標簽

    您可以根據實際情況,選擇用于標識實例的環境標簽。本示例無需選擇。

    配置ETL功能

    選擇是否配置ETL功能。關于ETL的更多信息,請參見什么是ETL。

    是否去除正反向任務的心跳表sql

    根據業務需求選擇是否在DTS實例運行時,在源庫中寫入心跳SQL信息。

    • :不在源庫中寫入心跳SQL信息,DTS實例可能會顯示有延遲。

    • :在源庫中寫入心跳SQL信息,可能會影響源庫的物理備份和克隆等功能。

  7. 單擊下一步配置庫表字段,配置待同步表在ClickHouse中的類型、主鍵列、排序鍵、分布鍵分區鍵信息。

    說明
    • DTS默認配置了一組數據,您可以將定義狀態選擇為全部后進行修改。

    • 主鍵列排序鍵可以是組合鍵,即您可以在對應的下拉框中選擇多個字段作為主鍵列排序鍵,且需要從主鍵列中選擇1個或者多個列作分區鍵;分布鍵只能選擇一個字段。更多關于主鍵列、排序鍵、分區鍵的信息,請參見CREATE TABLE。

    • 分區鍵可以不設置,但不可以選擇為可空的字段,否則同步任務將會失敗。

  8. 保存任務并進行預檢查。

    • 若您需要查看調用API接口配置該實例時的參數信息,請將鼠標光標移動至下一步保存任務并預檢查按鈕上,然后單擊氣泡中的預覽OpenAPI參數。

    • 若您無需查看或已完成查看API參數,請單擊頁面下方的下一步保存任務并預檢查

    說明
    • 在同步作業正式啟動之前,會先進行預檢查。只有預檢查通過后,才能成功啟動同步作業。

    • 如果預檢查失敗,請單擊失敗檢查項后的查看詳情,并根據提示修復后重新進行預檢查。

    • 如果預檢查產生警告:

      • 對于不可以忽略的檢查項,請單擊失敗檢查項后的查看詳情,并根據提示修復后重新進行預檢查。

      • 對于可以忽略無需修復的檢查項,您可以依次單擊點擊確認告警詳情、確認屏蔽、確定、重新進行預檢查,跳過告警檢查項重新進行預檢查。如果選擇屏蔽告警檢查項,可能會導致數據不一致等問題,給業務帶來風險。

  9. 預檢查通過率顯示為100%時,單擊下一步購買

  10. 購買頁面,選擇數據同步實例的計費方式、鏈路規格,詳細說明請參見下表。

    類別

    參數

    說明

    信息配置

    計費方式

    • 預付費(包年包月):在新建實例時支付費用。適合長期需求,價格比按量付費更實惠,且購買時長越長,折扣越多。

    • 后付費(按量付費):按小時扣費。適合短期需求,用完可立即釋放實例,節省費用。

    資源組配置

    實例所屬的資源組,默認為default resource group。更多信息,請參見什么是資源管理。

    鏈路規格

    DTS為您提供了不同性能的同步規格,同步鏈路規格的不同會影響同步速率,您可以根據業務場景進行選擇。更多信息,請參見數據同步鏈路規格說明

    訂購時長

    在預付費模式下,選擇包年包月實例的時長和數量,包月可選擇1~9個月,包年可選擇1年、2年、3年和5年。

    說明

    該選項僅在付費類型為預付費時出現。

  11. 配置完成后,閱讀并勾選《數據傳輸(按量付費)服務條款》。

  12. 單擊購買并啟動,并在彈出的確認對話框,單擊確定。

    您可在數據同步界面查看具體任務進度。

附錄

時間信息

數據類型

最小值

最大值

Date

1970-01-01 00:00:00

2149-06-06 00:00:00

Date32

1925-01-01 00:00:00

2283-11-11 00:00:00

DateTime

1970-01-01 08:00:00

2106-02-07 14:28:15

DateTime64

1925-01-01 08:00:00

2283-11-12 07:59:59

表和字段信息

表信息

在不使用庫表列名映射功能的情況下,需要創建的表有如下要求:

  • ClickHouse社區版實例:需要創建一個本地表和一個分布式表。分布式表的名稱需與源端表名一致,本地表的名稱為<分布式表名稱>+_local

  • ClickHouse企業版實例:需創建一個與源端名稱相同的表。

字段信息

說明
  • 23.8以下版本的社區版ClickHouse實例,可以使用select * from table_name final where _sign>0;語句查詢數據。其中,where條件可以過濾刪除的數據,表名后的final字段可以過濾相同排序鍵的數據。

  • 企業版和23.8及以上版本的社區版ClickHouse實例,可以直接執行相應的SQL查詢數據。若需過濾相同排序鍵的數據,可以在表名后添加final字段。

版本

名稱

數據類型

默認值

說明

23.8以下的社區版

_sign

Int8

1

DML操作的類型。

  • INSERT:記錄為1。

  • UPDATE:記錄為1。

  • DELETE:記錄為-1。

_version

UInt64

1

數據寫入ClickHouse的時間戳。

企業版和23.8及以上的社區版

is_deleted

Int8

0

記錄是否被刪除:

  • Insert:記錄為0。

  • Delete:記錄為1。

  • Update::記錄為0。

_version

UInt64

1

數據寫入ClickHouse的時間戳。