將資料從 Autonomous AI Transaction Processing 複製到 Microsoft Fabric Lakehouse
此快速入門示範如何使用 OCI GoldenGate 將資料從「自治式 AI 交易處理」複寫至 Microsoft Fabric Lakehouse。
開始之前
若要順利完成此快速啟動,您必須具備下列項目:
-
來源自治式 AI 交易處理執行處理。
-
Microsoft Fabric Lakehouse 工作區:
-
建立 Microsoft Entra ID 應用程式註冊。記下應用程式 (從屬端) ID、目錄 (用戶) ID 和從屬端加密密碼。
-
前往工作區的 Fabric,選取管理存取權,然後選取新增人員或群組。輸入已註冊的應用程式名稱,選取提供者角色,然後選取新增。
-
在您的工作區中建立湖倉一體的物件。
-
環境設定:自治式 AI 異動處理
如果您尚未設定複製的來源資料庫,您可以依照下列步驟來載入要用於此快速啟動的範例綱要。此快速入門針對來源資料庫使用自治式 AI 異動處理。
若要設定來源「自治式 AI 交易處理」,請執行下列動作:
-
下載並解壓縮範例資料庫綱要。
-
在 Oracle Cloud 主控台中,從「自治式 AI 資料庫」頁面選取您的「自治式 AI 異動處理 (ATP)」執行處理,以檢視其詳細資訊並存取「資料庫動作」。
-
解除鎖定 GGADMIN 使用者:
-
選取資料庫動作,然後選取資料庫使用者。
-
尋找 GGADMIN,然後選取其省略符號功能表 (三個點),然後選取編輯。
-
在「編輯使用者」面板中,輸入 GGADMIN 密碼,確認密碼,然後取消選取帳戶已鎖定。
-
選取套用變更。
-
-
載入來源範例綱要和資料:
-
從「資料庫」動作功能表的「開發」底下,選取 SQL 。
-
將命令檔從
OCIGGLL_OCIGGS_SETUP_USERS_ATP.sql複製並貼到 SQL 工作表中。 -
選取執行命令檔。「命令檔輸出」頁籤會顯示確認訊息。
-
清除 SQL 工作表,然後從
OCIGGLL_OCIGGS_SRC_USER_SEED_DATA.sql.複製並貼上 SQL 命令檔提示:您可能需要分別執行每個陳述式,SQL 工具才能順利執行命令檔。
-
若要驗證表格已順利建立,請關閉 SQL 視窗並重新開啟。在「導覽器」頁籤中,尋找
SRC_OCIGGLL綱要,然後從表格的個別下拉式清單中選取表格。
-
-
啟用補充記錄日誌:
-
清除 SQL 工作表。
-
輸入下列陳述式,然後選取執行陳述式:
ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;
-
作業 1:建立 OCI GoldenGate 資源
此快速啟動範例需要來源和目標的部署和連線。
-
為來源「自治式 AI 交易處理」執行處理建立 Oracle 部署。
-
為目標 Microsoft Fabric Lakehouse 建立大數據部署。
任務 2:新增擷取
-
在「部署」頁面上,選取來源「自治式 AI 交易處理」部署。
-
在部署詳細資料頁面上,選取啟動主控台。
-
以來源部署的管理員使用者名稱和密碼登入。
-
新增擷取。
作業 3:新增並執行分配路徑
-
如果使用 GoldenGate 證明資料存放區,請在目標大數據部署中建立「分送路徑」的使用者,否則請跳至步驟 3。
-
在來源 GoldenGate 部署主控台中,為在步驟 1 中建立的使用者新增「路徑連線」。
-
在來源 GoldenGate 部署主控台中,於左側導覽中選取路徑連線。
-
選取新增路徑連線 (加號圖示),然後完成下列作業:
-
在證明資料別名中,輸入
GGSNetwork。 -
在使用者 ID 中,輸入在步驟 1 中建立的使用者名稱。
-
輸入使用者的密碼兩次以進行驗證。
-
-
選取提交。
路徑連線會顯示在「路徑連線」清單中。
-
-
在來源建置主控台中,使用下列值新增分送路徑:
-
在來源選項頁面上:
-
對於來源擷取,請選取在任務 2 中建立的擷取。
-
在歷程檔名稱中,輸入兩個字元的名稱,例如
E1。
-
-
在目標選項頁面上:
-
在目標主機中,輸入目標部署的主機網域。
-
在連接埠號碼中,輸入
443。 -
在歷程檔名稱中,輸入兩個字元的名稱,例如
E1。 -
在別名中,輸入在步驟 2 中建立的「證明資料別名」。
-
-
-
在目標大數據部署主控台中,複查因「分送路徑」而建立的「接收者路徑」。
-
在目標 Big Data 部署主控台中,選取接收者服務。
-
複查路徑詳細資料。此路徑是由上一個步驟中建立的「分送路徑」所建立。
-
作業 4:新增並執行 Replicat
-
在目標 Big Data 部署主控台中,選取管理員服務,然後選取新增 Replicat (加號圖示)。
-
使用下列值新增 Replicat :
-
在「Replicat 資訊」頁面的 Replicat 類型下,選取傳統 Replicat ,輸入「處理作業名稱」,然後選取下一步。
-
在「複製選項」頁面上:
-
在名稱中,輸入「任務 2」的「追蹤」名稱。
-
若為目標,請選取 Microsoft Fabric Lakehouse。
-
針對格式,選取您要擷取至 Microsoft Fabric Lakehouse 的格式。
-
若為可用別名,請從下拉式清單中選取 Microsoft Fabric Lakehouse 連線。
-
-
在「受管理選項」頁面上,保留預設值。
-
在「Replicat 參數」頁面中,保留預設值。
-
在「Replicat 特性」頁面上,更新下列特性:
-
gg.eventhandler.onelake.workspace=<target_workspace_name> -
gg.eventhandler.onelake.lakehouse=<target_lakehouse_name>
-
-
-
選取建立並執行。
您可以返回「總覽」頁面,在此頁面複查 Replicat 詳細資訊。
工作 5:驗證複製
對來源「自治式 AI 交易處理」執行處理執行一些更新,以驗證對 Microsoft Fabric Lakehouse 的複寫。
-
在 Oracle Cloud 主控台中,開啟導覽功能表,選取 Oracle AI Database ,然後選取自治式 AI 異動處理。
-
在「自治式 AI 異動處理」執行處理清單中,選取您的來源執行處理以檢視其詳細資訊。
-
在資料庫詳細資訊頁面上,選取資料庫動作。
注意:您應該自動登入。如果不是,請使用資料庫證明資料登入。
-
在「資料庫動作」首頁上,選取 SQL 。
-
在工作表中輸入下列內容,然後選取執行命令檔。
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1000,'Houston',20,743113); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1001,'Dallas',20,822416); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1002,'San Francisco',21,157574); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1003,'Los Angeles',21,743878); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1004,'San Diego',21,840689); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1005,'Chicago',23,616472); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1006,'Memphis',23,580075); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1007,'New York City',22,124434); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1008,'Boston',22,275581); Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1009,'Washington D.C.',22,688002); -
在來源可承諾量部署主控台中,選取「擷取」名稱,然後選取統計資料。確認 SRC_OCIGGLL.SRC_CITY 有 10 個插入項目。
-
在目標 Big Data OCI GoldenGate 部署主控台中,選取 Replicat 名稱,然後選取統計資料。確認 SRC_OCIGGLL.SRC_CITY 有 10 個插入項目。
-
在 Oracle Cloud 主控台中,瀏覽至 Oracle Object Storage 貯體並檢查其內容。