本文介紹如何使用Data Transmission Service,將自建PostgreSQL遷移至RDS PostgreSQL。DTS支援結構遷移、全量資料移轉和增量資料移轉,同時使用這三種遷移類型可以實現在自建應用不停服的情況下,平滑地完成自建PostgreSQL資料庫遷移上雲。
注意事項
類型 | 說明 |
源庫限制 | 頻寬要求:源庫所屬的伺服器需具備足夠出口頻寬,否則將影響資料移轉速率。 待遷移的表需具備主鍵或唯一約束,且欄位具有唯一性,否則可能會導致目標資料庫中出現重複資料。 說明 若接收資料的目標表不是通過DTS建立(遷移類型未選中庫表結構遷移),則需確保該表與源庫中待遷移的表具備相同的主鍵或非空唯一約束,否則可能會導致目標資料庫中出現重複資料。 待遷移的資料庫名稱中間不能包含短劃線(-),例如dts-testdata。 如遷移對象為表層級,且需進行編輯(如表列名映射),則單次遷移任務僅支援遷移至多1000張表。當超出數量限制,任務提交後會顯示請求報錯,此時建議您拆分待遷移的表,分批配置多個任務,或者配置整庫的遷移任務。 DTS不支援遷移源庫中的暫存資料表、系統內部的觸發器(TRIGGER)、部分函數(關於PROCEDURE與FUNCTION的C語言函數和內建函式);DTS支援遷移部分自訂資料(TYPE為COMPOSITE、ENUM或RANGE),支援遷移的約束為主鍵、外鍵、唯一、CHECK約束。 如需進行增量遷移,WAL日誌: 需開啟,即設定wal_level參數的值為logical。 如為增量遷移任務,DTS要求來源資料庫的WAL日誌儲存24小時以上,如為全量遷移和增量遷移任務,DTS要求來源資料庫的WAL日誌至少保留7天以上(您可在全量遷移完成後將WAL日誌儲存時間設定為24小時以上),否則DTS可能因無法擷取WAL日誌而導致任務失敗,極端情況下甚至可能會導致資料不一致或丟失。由於您所設定的WAL日誌儲存時間低於DTS要求的時間進而導致的問題,不在DTS的SLA保障範圍內。
源庫的操作限制: 如自建PostgreSQL進行主備切換,會導致遷移失敗。 在庫表結構遷移和全量遷移階段,請勿執行庫或表結構變更的DDL操作,否則資料移轉任務會失敗。 由於源庫的邏輯訂閱本身存在使用限制,在包含增量任務的遷移執行個體運行期間,若源庫待遷移的單條資料在增量變更後超過256 MB,則可能會導致遷移執行個體運行失敗且無法恢複,您需要重新設定遷移執行個體。
若源庫有長事務,且執行個體包含增量遷移任務,則可能會導致源庫長事務提交前的預寫記錄檔WAL(Write-Ahead Logging)無法清理而堆積,從而造成源庫磁碟空間不足。 在遷移執行個體運行期間,若源庫進行了大版本升級,將會導致遷移執行個體運行失敗並且無法恢複,您需要重新設定遷移執行個體。
|
其他限制 | 由於源庫的主備節點可能存在延遲導致資料不一致,執行資料移轉時請使用源庫的主節點作為遷移的資料來源。 單個資料移轉任務只能遷移一個資料庫,如需遷移多個資料庫,您需要為每個資料庫配置資料移轉任務。 不支援遷移包含跨Schema繼承關係的表。 如果待遷移的表中包含SERIAL類型的欄位,源庫會自動為該欄位建立一個Sequence。因此在配置源庫對象時,若遷移類型選中了庫表結構遷移,則建議您同時選中Sequence或整Schema遷移,否則可能會導致遷移執行個體運行失敗。 增量資料移轉期間,如果遷移對象的選擇粒度為Schema,在待遷移的Schema中建立了新的表或使用RENAME命令重建了待遷移的表,您需要在對該表寫入資料前執行ALTER TABLE schema.table REPLICA IDENTITY FULL; 命令。執行該命令期間,建議您不要有鎖表操作,否則會導致表鎖死。 DTS的校正對象為資料內容,暫不支援Sequence等中繼資料的校正,您需要自行校正。 由於業務切換到目標端後,新寫入的Sequence不會按照源庫的Sequence最大值作為初始值去遞增,您需要在業務切換前,更新目標庫的Sequence值。更多資訊,請參見更新目標庫的Sequence值。 DTS會在源庫中建立以下暫存資料表,用於擷取增量資料的DDL、增量表的結構、心跳資訊等。在遷移期間,請勿刪除源庫中的暫存資料表,否則會導致DTS任務異常。暫存資料表會在DTS執行個體釋放後自動刪除。 public.dts_pg_class 、public.dts_pg_attribute 、public.dts_pg_type 、public.dts_pg_enum 、public.dts_postgres_heartbeat 、public.dts_ddl_command 、public.dts_args_session 。
為保障增量資料移轉延遲時間展示的準確性,DTS會在源庫中新增一個名為dts_postgres_heartbeat 的心跳錶。 增量資料移轉期間,DTS會在源庫中建立首碼為dts_sync_ 的replication slot用於複製資料。通過該replication slot,DTS可以擷取源庫15分鐘內的增量日誌。 說明 當釋放遷移任務或遷移失敗時,DTS會主動清理該replication slot;如果自建PostgreSQL發生了主備切換,則需要您登入備庫來手動清理。 
若為全量遷移或增量遷移任務,且來源資料庫中要遷移的表包含外鍵、觸發器、事件觸發程序,如果目標庫帳號為高許可權帳號或者super許可權帳號,全量或增量遷移時DTS會以Session層級暫時將session_replication_role的參數值設定為replica;如果目標庫帳號沒有該許可權,您需要手動將目標資料庫中session_replication_role的參數值設定為replica。在此期間(全量遷移或增量遷移過程中session_replication_role的參數值為replica),若源庫存在串聯更新、刪除操作,則可能會導致資料不一致。在DTS遷移任務釋放後,您可以將session_replication_role的參數值改回origin。 執行資料移轉前需評估源庫和目標庫的效能,同時建議業務低峰期執行資料移轉。否則全量資料移轉時DTS佔用源和目標庫一定讀寫資源,可能會導致資料庫的負載上升。 由於全量資料移轉會並發執行INSERT操作,導致目標資料庫的表產生片段,因此全量遷移完成後目標庫的表格儲存體空間會比源庫的表格儲存體空間大。 請確認DTS對資料類型為FLOAT或DOUBLE的列的遷移精度是否符合業務預期。DTS會通過ROUND(COLUMN,PRECISION) 來讀取這兩類列的值。如果沒有明確定義其精度,DTS對FLOAT的遷移精度為38位,對DOUBLE的遷移精度為308位。 DTS會嘗試恢複七天之內遷移失敗任務。因此業務切換至目標執行個體前,請務必結束或釋放該任務,或者將DTS訪問目標執行個體帳號的寫入權限用revoke 命令回收。避免該任務被自動回復後,源端資料覆蓋目標執行個體的資料。 若執行個體運行失敗,DTS技術支援人員將在8小時內嘗試恢複該執行個體。在恢複失敗執行個體的過程中,可能會對該執行個體進行重啟、調整參數等操作。 說明 在調整參數時,僅會修改執行個體的參數,不會對資料庫中的參數進行修改。可能修改的參數,包括但不限於修改執行個體參數中的參數。
|
特殊情況 | 當源執行個體為自建PostgreSQL時,需要確保max_wal_senders和max_replication_slots的參數值,均大於當前資料庫複寫槽已使用數與需要以該自建PostgreSQL為源建立的DTS執行個體數的總和。 當源執行個體為Google Cloud Platform Cloud SQL for PostgreSQL時,源庫的資料庫帳號需填入具有cloudsqlsuperuser許可權的帳號。在選擇遷移對象時需選擇此帳號有許可權管理的對象,或者給此帳號添加目標對象的Owner許可權。 說明 具有cloudsqlsuperuser許可權的帳號,無法管理Owner為其他cloudsqlsuperuser許可權帳號的資料。
|
支援增量遷移的SQL操作
操作類型 | SQL動作陳述式 |
DML | INSERT、UPDATE、DELETE |
DDL | |
資料庫帳號的許可權要求
資料庫 | 結構遷移 | 全量遷移 | 增量遷移 |
自建PostgreSQL資料庫 | pg_catalog的usage許可權 | 遷移對象的select許可權 | superuser |
RDS PostgreSQL執行個體 | 遷移對象的create、usage許可權 | schema的owner許可權 | schema的owner許可權 |
資料庫帳號建立及授權方法:
準備工作
自建PostgreSQL(所有版本)需執行如下準備工作。
登入自建PostgreSQL所屬的伺服器。
執行如下命令,查詢資料庫已使用複製槽數量。
select count(1) from pg_replication_slots;
修改設定檔postgresql.conf
,將設定檔中的wal_level
設定為logical
,並確保max_wal_senders
和max_replication_slots
的參數值,均大於資料庫複寫槽已使用數與需要以該自建PostgreSQL為源建立的DTS執行個體數的總和。
# - Settings -
wal_level = logical # minimal, replica, or logical
# (change requires restart)
......
# - Sending Server(s) -
# Set these on the master and on any standby that will send replication data.
max_wal_senders = 10 # max number of walsender processes
# (change requires restart)
#wal_keep_segments = 0
#wal_sender_timeout = 60s
max_replication_slots = 10 # max number of replication slots
# (change requires restart)
說明
設定檔修改完成後,您需要重啟自建PostgreSQL使參數生效。
將DTS的IP地址加入至自建PostgreSQL的設定檔pg_hba.conf中。您只需添加目標資料庫所在地區對應的DTS IP位址區段,詳情請參見添加DTS伺服器的IP位址區段。
根據待遷移對象所屬的資料庫和Schema資訊,在目標RDS PostgreSQL中建立相應資料庫和Schema(Schema名稱須一致),詳情請參見建立資料庫和Schema 管理。
若自建PostgreSQL版本為9.4.8~10.0,則您還需執行如下準備工作。
下載PostgreSQL源碼並完成編譯安裝。
根據源庫自建PostgreSQL的版本,從PostgreSQL官網下載對應版本的源碼。
依次執行命令sudo ./configure
、sudo make
、sudo make install
,配置、編譯並安裝源碼。
重要
編譯安裝PostgreSQL時,PostgreSQL的作業系統版本需與GCC(GNU編譯器套件)版本保持一致。
如執行sudo ./configure
遇到報錯,您可以根據報錯提示調整命令。例如,報錯資訊為readline library not found. Use --without-readline to disable readline support.
,則您可以調整命令為sudo ./configure --without-readline
.
如您選擇其他方式安裝PostgreSQL,需要在系統版本以及GCC版本相同的測試環境下,編譯ali_decoding。
下載DTS提供的外掛程式ali_decoding並完成編譯安裝。
下載ali_decoding。
將ali_decoding整個目錄拷貝至PostgreSQL(已完成編譯安裝)的contrib目錄中。
進入ali_decoding目錄,將Makefile檔案的內容替換為如下:
# contrib/ali_decoding/Makefile
MODULE_big = ali_decoding
MODULES = ali_decoding
OBJS = ali_decoding.o
DATA = ali_decoding--0.0.1.sql ali_decoding--unpackaged--0.0.1.sql
EXTENSION = ali_decoding
NAME = ali_decoding
#subdir = contrib/ali_decoding
#top_builddir = ../..
#include $(top_builddir)/src/Makefile.global
#include $(top_srcdir)/contrib/contrib-global.mk
#PG_CONFIG = /usr/pgsql-9.6/bin/pg_config
#pgsql_lib_dir := $(shell $(PG_CONFIG) --libdir)
#PGXS := $(shell $(PG_CONFIG) --pgxs)
#include $(PGXS)
# 源碼安裝用以下
ifdef USE_PGXS
PG_CONFIG = pg_config
PGXS := $(shell $(PG_CONFIG) --pgxs)
include $(PGXS)
else
subdir = contrib/ali_decoding
top_builddir = ../..
include $(top_builddir)/src/Makefile.global
include $(top_srcdir)/contrib/contrib-global.mk
endif
進入ali_decoding目錄,依次執行命令sudo make
、sudo make install
,編譯ali_decoding,並得到安裝ali_decoding所需的檔案。
將如下檔案複製至指定位置。
根據待遷移對象所屬的資料庫和Schema資訊,在目標RDS PostgreSQL中建立相應資料庫和Schema(Schema名稱須一致),詳情請參見建立資料庫和Schema 管理。
操作步驟
進入目標地區的遷移工作清單頁面(二選一)。
單擊創建任務,進入任務配置頁面。
配置源庫及目標庫資訊。
類別 | 配置 | 說明 |
無 | 任務名稱 | DTS會自動產生一個任務名稱,建議配置具有業務意義的名稱(無唯一性要求),便於後續識別。 |
源庫資訊 | 選擇已有串連資訊 | |
資料庫類型 | 選擇PostgreSQL。 |
接入方式 | 根據源庫的部署位置進行選擇,本文以雲企業網CEN為例介紹配置流程。 說明 當源執行個體為自建資料庫時,您還需要執行相應的準備工作,詳情請參見準備工作。 |
執行個體地區 | 選擇自建PostgreSQL資料庫所屬地區。 |
雲企業網執行個體ID | 選擇自建PostgreSQL資料庫所屬雲企業網的執行個體ID。 |
已和資料庫聯通的VPC網路 | 選擇與自建PostgreSQL資料庫互聯的VPC網路。 |
網域名稱或IP地址 | 填入自建PostgreSQL資料庫的伺服器IP地址。 |
連接埠 | 填入自建PostgreSQL資料庫的服務連接埠,預設為5432。 |
資料庫名稱 | 填入自建PostgreSQL中遷移對象所屬資料庫的名稱。 |
資料庫帳號 | 填入自建PostgreSQL的資料庫帳號,許可權要求,請參見資料庫帳號的許可權要求。 |
資料庫密碼 | 填入該資料庫帳號對應的密碼。 |
串連方式 | 請根據實際情況選擇,本樣本選擇非加密串連。 若您需要SSL加密的方式串連資料庫,請選擇SSL安全連線,並根據實際情況上傳CA 憑證、客戶端認證、客戶端認證私密金鑰,輸入客戶端認證私密金鑰密碼。 說明 若自建PostgreSQL資料庫選擇了SSL安全連線,則必須上傳CA 憑證。 若您需要使用用戶端認證,則需要同時上傳客戶端認證和客戶端認證私密金鑰,並輸入客戶端認證私密金鑰密碼。 RDS PostgreSQL執行個體的SSL加密功能,請參見SSL鏈路加密。
|
目標庫資訊 | 選擇已有串連資訊 | |
資料庫類型 | 選擇PostgreSQL。 |
接入方式 | 選擇雲執行個體。 |
執行個體地區 | 選擇目標RDS PostgreSQL執行個體所屬地區。 |
執行個體ID | 選擇目標RDS PostgreSQL執行個體ID。 |
資料庫名稱 | 填入目標RDS PostgreSQL執行個體中接收遷移對象的資料庫名稱。 |
資料庫帳號 | 填入目標RDS PostgreSQL執行個體的資料庫帳號,許可權要求,請參見資料庫帳號的許可權要求。 |
資料庫密碼 | 填入該資料庫帳號對應的密碼。 |
串連方式 | 請根據實際情況選擇,本樣本選擇非加密串連。 若您需要SSL加密的方式串連資料庫,請選擇SSL安全連線,並根據實際情況上傳CA 憑證、客戶端認證、客戶端認證私密金鑰,輸入客戶端認證私密金鑰密碼。 說明 若自建PostgreSQL資料庫選擇了SSL安全連線,則必須上傳CA 憑證。 若您需要使用用戶端認證,則需要同時上傳客戶端認證和客戶端認證私密金鑰,並輸入客戶端認證私密金鑰密碼。 RDS PostgreSQL執行個體的SSL加密功能,請參見SSL鏈路加密。
|
配置完成後,在頁面下方單擊測試連接以進行下一步。
配置任務對象。
在對象配置頁面,配置待遷移的對象。
配置 | 說明 |
遷移類型 | |
目標已存在表的處理模式 | |
目標庫對象名稱大小寫策略 | 您可以配置目標執行個體中遷移對象的庫名、表名和列名的英文大小寫策略。預設情況下選擇DTS預設策略,您也可以選擇與源庫、目標庫預設策略保持一致。更多資訊,請參見目標庫對象名稱大小寫策略。 |
源庫對象 | 在源庫對象框中單擊待遷移的對象,然後單擊 將其移動到已選擇對象框。 |
已選擇對象 | 說明 如果使用了對象名映射功能,可能會導致依賴這個對象的其他對象遷移失敗。 如需設定WHERE條件過濾資料,請在已選擇對象中右擊待遷移的表,在彈出的對話方塊中設定過濾條件。設定方法請參見設定過濾條件。 如需按庫或表層級選擇遷移的SQL操作,請在已選擇對象中右擊待遷移對象,並在彈出的對話方塊中選擇所需遷移的SQL操作。
|
單擊下一步高級配置,進行進階參數配置。
配置 | 說明 |
選擇調度該任務的專屬叢集 | DTS預設將任務調度到共用叢集上,您無需選擇。若您希望任務更加穩定,可以購買專屬叢集來運行DTS遷移任務。更多資訊,請參見什麼是DTS專屬叢集。 |
源庫、目標庫無法串連後的重試時間 | 在遷移任務啟動後,若源庫或目標庫串連失敗則DTS會報錯,並會立即進行持續的重試串連,預設重試720分鐘,您也可以在取值範圍(10~1440分鐘)內自訂重試時間,建議設定30分鐘以上。如果DTS在設定的時間內重新串連上源、目標庫,遷移任務將自動回復。否則,遷移任務將失敗。 |
源庫、目標庫出現其他問題後的重試時間 | 在遷移任務啟動後,若源庫或目標庫出現非串連性的其他問題(如DDL或DML執行異常),則DTS會報錯並會立即進行持續的重試操作,預設持續重試時間為10分鐘,您也可以在取值範圍(1~1440分鐘)內自訂重試時間,建議設定10分鐘以上。如果DTS在設定的重試時間內相關操作執行成功,遷移任務將自動回復。否則,遷移任務將會失敗。 重要 源庫、目標庫出現其他問題後的重試時間的值需要小於源庫、目標庫無法串連後的重試時間的值。 |
是否限制全量遷移速率 | 在全量遷移階段,DTS將佔用源庫和目標庫一定的讀寫資源,可能會導致資料庫的負載上升。您可以根據實際情況,選擇是否對全量遷移任務進行限速設定(設定每秒查詢源庫的速率QPS、每秒全量遷移的行數RPS和每秒全量遷移的數據量(MB)BPS),以緩解目標庫的壓力。 |
是否限制增量遷移速率 | 您也可以根據實際情況,選擇是否對增量遷移任務進行限速設定(設定每秒增量遷移的行數RPS和每秒增量遷移的數據量(MB)BPS),以緩解目標庫的壓力。 |
環境標籤 | 您可以根據實際情況,選擇用於標識執行個體的環境標籤。本樣本無需選擇。 |
配置ETL功能 | 選擇是否配置ETL功能。關於ETL的更多資訊,請參見什麼是ETL。 |
監控警示 | 是否設定警示,當遷移失敗或延遲超過閾值後,將通知警示連絡人。 |
單擊下一步資料校正,進行資料校正任務配置。
若您需要使用資料校正功能,配置方法請參見配置資料校正。
儲存任務並進行預檢查。
購買執行個體。
預檢查通過率顯示為100%時,單擊下一步購買。
在購買頁面,選擇資料移轉執行個體的鏈路規格,詳細說明請參見下表。
類別 | 參數 | 說明 |
資訊配置 | 資源群組配置 | 選擇執行個體所屬的資源群組,預設為default resource group。更多資訊,請參見什麼是資源管理。 |
鏈路規格 | DTS為您提供了不同效能的遷移規格,遷移鏈路規格的不同會影響遷移速率,您可以根據業務情境進行選擇。更多資訊,請參見資料移轉鏈路規格說明。 |
配置完成後,閱讀並選中《資料轉送(隨用隨付)服務條款》。
單擊購買並啟動,並在彈出的確認對話方塊,單擊確定。
您可在資料移轉介面查看具體進度。