將資料從自治式 AI 異動處理複寫至 Apache Iceberg

瞭解如何在 OCI GoldenGate 中將資料從自治式 AI 交易處理複寫至 Apache Iceberg。

開始之前

若要順利完成此快速啟動，您必須具備：

來源自治式 AI 交易處理
目標 Apache Iceberg 環境：
- OCI GoldenGate 支援 Azure Data Lake Storage、Amazon S3 和 Google Cloud Storage，作為 Apache Iceberg 表格的儲存服務。
- OCI GoldenGate 支援適用於 Apache Iceberg 的 Hadoop、Nessie、AWS Glue、Polaris、REST 和 JDBC 目錄。

環境設定：自治式 AI 異動處理

如果您尚未設定複製的來源資料庫，您可以依照下列步驟來載入要用於此快速啟動的範例綱要。此快速入門針對來源資料庫使用自治式 AI 異動處理。

若要設定來源「自治式 AI 交易處理」，請執行下列動作：

下載並解壓縮範例資料庫綱要。
在 Oracle Cloud 主控台中，從「自治式 AI 資料庫」頁面選取您的「自治式 AI 異動處理 (ATP)」執行處理，以檢視其詳細資訊並存取「資料庫動作」。
解除鎖定 GGADMIN 使用者：
1. 選取資料庫動作，然後選取資料庫使用者。
2. 尋找 GGADMIN，然後選取其省略符號功能表 (三個點)，然後選取編輯。
3. 在「編輯使用者」面板中，輸入 GGADMIN 密碼，確認密碼，然後取消選取帳戶已鎖定。
4. 選取套用變更。
載入來源範例綱要和資料：
1. 從「資料庫」動作功能表的「開發」底下，選取 SQL 。
2. 將命令檔從 OCIGGLL_OCIGGS_SETUP_USERS_ATP.sql 複製並貼到 SQL 工作表中。
3. 選取執行命令檔。「命令檔輸出」頁籤會顯示確認訊息。
4. 清除 SQL 工作表，然後從 OCIGGLL_OCIGGS_SRC_USER_SEED_DATA.sql. 複製並貼上 SQL 命令檔
  
  提示：您可能需要分別執行每個陳述式，SQL 工具才能順利執行命令檔。
5. 若要驗證表格已順利建立，請關閉 SQL 視窗並重新開啟。在「導覽器」頁籤中，尋找 SRC_OCIGGLL 綱要，然後從表格的個別下拉式清單中選取表格。
啟用補充記錄日誌：
1. 清除 SQL 工作表。
2. 輸入下列陳述式，然後選取執行陳述式：
```
ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;
```

任務 1：建立資源

此快速啟動範例需要來源和目標的部署和連線。

任務 2：新增擷取

在「部署」頁面上，選取來源「自治式 AI 交易處理」部署。
在部署詳細資料頁面上，選取啟動主控台。
以來源部署的管理員使用者名稱和密碼登入。
新增擷取。

作業 3：新增並執行分配路徑

如果使用 GoldenGate 證明資料存放區，請在目標大數據部署中建立「分送路徑」的使用者，否則請跳至步驟 3。
在來源 GoldenGate 部署主控台中，為在步驟 1 中建立的使用者新增「路徑連線」。
1. 在來源 GoldenGate 部署主控台中，於左側導覽中選取路徑連線。
2. 選取新增路徑連線 (加號圖示)，然後完成下列作業：
  1. 在證明資料別名中，輸入 GGSNetwork。
  2. 在使用者 ID 中，輸入在步驟 1 中建立的使用者名稱。
  3. 輸入使用者的密碼兩次以進行驗證。
3. 選取提交。
  
  路徑連線會顯示在「路徑連線」清單中。
在來源建置主控台中，使用下列值新增分送路徑：
1. 在來源選項頁面上：
  - 對於來源擷取，請選取在任務 2 中建立的擷取。
  - 在歷程檔名稱中，輸入兩個字元的名稱，例如 E1。
2. 在目標選項頁面上：
  - 在目標主機中，輸入目標部署的主機網域。
  - 在連接埠號碼中，輸入 443。
  - 在歷程檔名稱中，輸入兩個字元的名稱，例如 E1。
  - 在別名中，輸入在步驟 2 中建立的「證明資料別名」。
在目標大數據部署主控台中，複查因「分送路徑」而建立的「接收者路徑」。
1. 在目標 Big Data 部署主控台中，選取接收者服務。
2. 複查路徑詳細資料。此路徑是由上一個步驟中建立的「分送路徑」所建立。

作業 4：新增並執行 Replicat

若要新增並執行 Replicat，請執行下列動作：

在目標 Big Data 部署主控台導覽功能表中，選取 Replicats ，然後選取新增 Replicat (加號圖示)。
在「新增 Replicat」面板的 Replicat 資訊頁面中，視需要完成欄位，然後選取下一步：
- 針對 Replicat 類型，選取傳統 Replicat
- 輸入長度不超過 5 個字元的程序名稱。
- 輸入描述，以協助區分此處理與其他處理。
在複製選項頁面上，視需要完成欄位，然後選取下一步：
1. 在複製軌跡中，輸入「擷取」軌跡名稱。
2. 在目標中，選取 Apache Iceberg 。
3. 針對格式，選取您要擷取至 Apache Iceberg 的格式。預設值為 Parquet。
4. 對於可用別名，請從下拉式清單中選取 Apache Iceberg 連線。
在「受管理選項」頁面上，保留預設設定，然後選取下一步。
在「Replicat 參數」頁面上，保留預設設定，然後選取下一步。
在「Replicat 特性」頁面上，更新標示為 TODO 的欄位，然後選取建立並執行。

如需詳細資訊，請參閱 Apache Iceberg 目標詳細資訊。

工作 5：驗證複製

若要驗證複製，請執行來源可承諾量執行環境的更新。

在 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 貯體並檢查其內容。