將資料從 Autonomous AI Transaction Processing 複製到 Microsoft Fabric Eventstream

瞭解如何使用 OCI GoldenGate 將資料從 Autonomous AI Transaction Processing 來源複製到 Microsoft Fabric Eventstream

開始之前

若要順利完成此快速啟動,您必須具備下列項目:

環境設定:自治式 AI 交易處理

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

若要設定來源 Autonomous AI Transaction Processing

  1. 下載並解壓縮範例資料庫綱要
  2. 在 Oracle Cloud 主控台中,從自治式 AI 資料庫頁面選取您的自治式 AI 交易處理 (ATP) 執行處理,以檢視其詳細資訊並存取資料庫動作。
  3. 解除鎖定 GGADMIN 使用者:
    1. 按一下「資料庫動作」,然後按一下「資料庫使用者」。
    2. 尋找 GGADMIN,然後按一下其省略符號功能表 (三個點),然後選取編輯
    3. 在「編輯使用者」面板中,輸入 GGADMIN 密碼,確認密碼,然後取消選取帳戶已鎖定
    4. 按一下套用變更
  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 綱要,然後從表格的個別下拉式清單中選取表格。
  5. 啟用補充記錄日誌:
    1. 清除 SQL 工作表。
    2. 輸入下列敘述句,然後按一下執行敘述句
      ALTER PLUGGABLE DATABASE ADD SUPPLEMENTAL LOG DATA;

任務 2:新增擷取

  1. 在「部署」頁面上,選取來源「自治式 AI 交易處理」部署。
  2. 在部署詳細資訊頁面上,按一下啟動主控台
  3. 以來源部署的管理員使用者名稱和密碼登入。
  4. 新增交易資訊
  5. 新增 Extract

作業 3:新增分配路徑

  1. 如果使用 GoldenGate 證明資料存放區,請在目標大數據部署中建立分送路徑的使用者,否則請跳至步驟 3.
  2. 來源 ATP GoldenGate 部署主控台中,為在步驟 1 中建立的使用者新增「路徑連線」。
    1. 在來源 ATP GoldenGate 部署主控台中,按一下左側導覽中的路徑連線
    2. 按一下新增路徑連線 (加號圖示),然後完成下列作業:
      1. 證明資料別名中,輸入 GGSNetwork
      2. 使用者 ID 中,輸入在步驟 1 中建立的使用者名稱。
      3. 輸入使用者的密碼兩次以進行驗證。
    3. 按一下提交

      路徑連線會顯示在「路徑連線」清單中。

  3. 在「來源 ATP 建置主控台」中,使用下列值新增分配路徑
    1. 來源選項頁面上:
      • 對於來源擷取,請選取在任務 2 中建立的擷取。
      • 歷程檔名稱中,輸入兩個字元的名稱,例如 E1
    2. 目標選項頁面上:
      • 目標主機中,輸入目標部署的主機網域。
      • 連接埠號碼中,輸入 443
      • 歷程檔名稱中,輸入兩個字元的名稱,例如 E1
      • 別名中,輸入在步驟 2 中建立的「證明資料別名」。
  4. 在「目標大數據」建置主控台中,複查因 Distribution Path 而建立的 Receiver Path
    1. 在目標 Big Data 部署主控台中,按一下 Receiver Service
    2. 複查路徑詳細資訊。此路徑是由上一個步驟中建立的 Distribution Path 所建立。

工作 4:新增並執行 Replicat

  1. 在目標 Big Data 部署主控台中,按一下 Replicats ,然後按一下 Add Replicat (加號圖示)。
  2. 使用下列值新增 Replicat
    1. 在「Replicat 資訊」頁面的 Replicat 類型下,選取 Classic Replicat ,輸入程序名稱,然後按下一步
    2. 在「複製選項」頁面上:
      • 名稱中,輸入「工作 2」的「歷程檔」名稱。
      • 目標中,選取 Microsoft Fabric Eventstream
      • 針對格式,選取您要擷取至 Microsoft Fabric Eventstream 的格式。預設值為 JSON。
      • 對於可用別名,請從下拉式清單中選取 Microsoft Fabric Eventstream 連線。
    3. 在「受管理選項」頁面上,保留預設設定。
    4. 在「Replicat 參數」頁面上,保留預設值。
    5. 在「Replicat 特性」頁面上,更新標示為 #TODO 的欄位。
  3. 按一下「建立並執行」。
您會返回「複本」頁面,您可以在此複查 Replicat 詳細資訊。

工作 5:驗證複製

對來源 Autonomous Transaction Processing 執行處理執行一些更新,以驗證對 Microsoft Fabric Lakehouse 的複寫。
  1. Oracle Cloud 主控台中,開啟導覽功能表,選取 Oracle AI Database,然後選取自治式 AI 異動處理
  2. 自治式 AI 交易處理執行處理清單中,選取您的來源執行處理以檢視其詳細資訊。
  3. 在資料庫詳細資訊頁面上,按一下資料庫動作

    附註:

    您應該自動登入。如果不是,請使用資料庫證明資料登入。
  4. 在「資料庫」動作首頁上,選取 SQL
  5. 在工作表中輸入下列內容,然後按一下執行命令檔
    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);
  6. 在來源 ATP 建置主控台中,選取 Extract 名稱,然後按一下統計資料。確認 SRC_OCIGGLL.SRC_CITY 有 10 個插入。
  7. 在目標 Big Data OCI GoldenGate 部署主控台中,選取 Replicat 名稱,然後按一下統計資料。確認 SRC_OCIGGLL.SRC_CITY 有 10 個插入。