共用方式為


CDC 控制工作

適用於: SQL Server Azure Data Factory 中的 SSIS Integration Runtime

重要

CDC 流程元件,包括 CDC 控制工作、CDC 來源和 CDC 分隔器,皆已被取代。 如需詳細資料,請參閱公告

CDC 控制工作是用來控制異動資料擷取 (CDC) 封裝的開發週期。 它會處理 CDC 封裝與初始載入封裝的同步處理,以及 CDC 封裝執行中所處理之記錄序號 (LSN) 範圍的管理。 此外,CDC 控制工作也會處理錯誤狀況和復原。

CDC 控制工作在 SSIS 封裝變數中維護 CDC 封裝的狀態,也可以將它保存在資料庫資料表中,以便於跨封裝啟動和在一起執行通用 CDC 處理序的多個封裝之間維護狀態 (例如某個工作可能負責初始載入,而另一個工作則負責滴漏式饋送更新)。

CDC 控制工作支援兩個作業群組。 一個群組處理初始載入和變更處理的同步處理,另一個群組則管理 CDC 封裝執行期間 LSN 變更處理範圍及追蹤何者已成功處理。

下列作業會處理初始載入和變更處理的同步處理:

作業 描述
ResetCdcState 此作業是用來重設與目前 CDC 內容相關聯的永續性 CDC 狀態。 執行此作業之後,LSN 時間戳記 sys.fn_cdc_get_max_lsn 資料表中的目前最大 LSN 就會變成下一個處理範圍的範圍開頭。 此作業需要來源資料庫的連接。
MarkInitialLoadStart 在初始載入封裝開始時使用此作業,以便在初始載入封裝開始讀取來源資料表之前記錄來源資料庫中目前的 LSN。 這需要來源資料庫的連接,以呼叫 sys.fn_cdc_get_max_lsn

如果您在 SQL Server CDC (亦即非 Oracle) 上工作時選取了 MarkInitialLoadStart,則連線管理員中指定的使用者就必須是 db_owner 或系統管理員 (sysadmin)。
MarkInitialLoadEnd 在初始載入封裝結束時使用此作業,以便在初始載入封裝完成讀取來源資料表之後記錄來源資料庫中目前的 LSN。 這個 LSN 的決定方式如下:記錄進行此作業時的目前時間,然後在 CDC 資料庫中查詢 cdc.lsn_time_mapping 資料表,尋找該時間之後發生的變更。

如果您在 SQL Server CDC (亦即非 Oracle) 上工作時選取了 MarkInitialLoadEnd,則連線管理員中指定的使用者就必須是 db_owner 或系統管理員 (sysadmin)。
MarkCdcStart 此作業是在從快照集資料庫進行初始載入時使用。 在此情況下,變更處理應該在快照集 LSN 之後立即開始。 您可以指定要使用的快照集資料庫名稱,CDC 控制工作就會在 SQL Server 中查詢快照集 LSN。 您還可以選擇直接指定快照集 LSN。

如果您在 SQL Server CDC (亦即非 Oracle) 上工作時選取了 MarkCdcStart,則連線管理員中指定的使用者就必須是 db_owner 或系統管理員 (sysadmin)。

下列作業用來管理處理範圍:

作業 描述
GetProcessingRange 此作業是在叫用使用 CDC 來源資料流程的資料流程之前使用。 叫用此作業時,它會建立 CDC 來源資料流程所讀取的 LSN 範圍。 此範圍會儲存在資料流程處理期間 CDC 來源所使用的 SSIS 封裝變數中。

如需儲存之狀態的詳細資訊,請參閱 定義狀態變數
MarkProcessedRange 在每個 CDC 執行之後 (CDC 資料流程順利完成之後) 執行此作業,以便記錄 CDC 執行期間完整處理的最後一個 LSN。 下次執行 GetProcessingRange 時,這個位置就是下一個處理範圍的開頭。

處理 CDC 狀態持續性

CDC 控制工作會在啟動之間維護永續性狀態。 儲存在 CDC 狀態中的資訊用來決定及維護 CDC 封裝的處理範圍,以及用於偵測錯誤狀態。 永續性狀態儲存為字串。 如需詳細資訊,請參閱 定義狀態變數

CDC 控制工作支援兩種狀態持續性類型。

  • 手動狀態持續性:在此情況下,CDC 控制工作會管理儲存在封裝變數中的狀態,但是封裝開發人員必須在呼叫 CDC 控制之前從永續性存放區讀取變數,然後在最後一次呼叫 CDC 控制而且 CDC 執行完成之後將變數寫回該永續性存放區。

  • 自動狀態持續性:CDC 狀態會儲存在資料庫資料表中。 此狀態是在 [要用於儲存狀態的資料表] 屬性 (位於儲存狀態的選定連接管理員) 所指名資料表中, StateName 屬性所提供的名稱下儲存。 預設是來源連接管理員,但常見作法是將它做為目標連接管理員。 CDC 控制工作會更新狀態資料表中的狀態值,並認可此值做為環境交易的一部分。

錯誤處理

在下列情況下,CDC 控制工作可能會報告錯誤:

  • 它無法讀取 CDC 永續性狀態或永續性狀態更新失敗。

  • 它無法從來源資料庫讀取目前的 LSN 資訊。

  • CDC 狀態讀取不一致。

在所有這些情況下,CDC 控制工作都會報告錯誤,而 SSIS 則會以處理控制流程錯誤的標準方式予以處理。

在未呼叫標記處理的範圍的情況下,直接在取得處理範圍作業之後叫用另一個取得處理範圍作業時,CDC 控制工作可能也會報告警告。 這種情況表示上次執行失敗,或者另一個 CDC 封裝可能正在以相同的 CDC 狀態名稱下執行。

設定 CDC 控制工作

您可以透過 SSIS 設計師或以程式設計方式設定屬性。

本節內容

定義狀態變數

CDC 控制工作編輯器

使用 [CDC 控制工作編輯器] 對話方塊,即可設定 CDC 控制工作。 CDC 控制工作組態包括定義 CDC 資料庫的連接、CDC 工作作業,以及狀態管理資訊。

若要了解有關 CDC 控制工作的詳細資訊,請參閱< CDC Control Task>。

若要開啟 CDC 控制工作編輯器

  1. 在 SQL Server Data Tools 中,開啟具有 CDC 控制工作的 SQL Server 2019 Integration Services (SSIS) 套件。

  2. 在 [控制流程] 索引標籤中,按兩下 CDC 控制工作。

選項

SQL Server CDC 資料庫 ADO.NET 連接管理員
從清單中選取現有的連接管理員,或按一下 [新增] 建立新的連接。 它必須連線到為 CDC 啟用且包含所選變更資料表的 SQL Server 資料庫。

CDC 控制作業
選取要針對此工作執行的作業。 所有作業都會使用儲存在 SSIS 封裝變數中的狀態變數,這個變數會儲存狀態並且在封裝中的不同元件之間傳遞狀態。

  • 標記初始載入開始:此作業是在從不含快照集的使用中資料庫執行初始載入時使用。 初始載入封裝開始讀取來源資料表之前,系統會在初始載入封裝的開頭叫用此作業,以便在來源資料庫中記錄目前的 LSN。 這需要來源資料庫的連接。

    如果您在 SQL Server CDC (亦即非 Oracle) 上工作時選取了 [標記初始載入開始],則連接管理員中指定的使用者就必須是 db_owner系統管理員 (sysadmin)

  • 標記初始載入結束:此作業是在從不含快照集的使用中資料庫執行初始載入時使用。 初始載入封裝讀取來源資料表完成之後,系統會在初始載入封裝的結尾叫用此作業,以便在來源資料庫中記錄目前的 LSN。 這個 LSN 的決定方式如下:記錄進行此作業時的目前時間,然後在 CDC 資料庫中查詢 cdc.lsn_time_mapping 資料表,尋找該時間之後發生的變更。

    如果您在 SQL Server CDC (亦即非 Oracle) 上工作時選取了 [標記初始載入結束],則連接管理員中指定的使用者就必須是 db_owner系統管理員 (sysadmin)

  • 標記 CDC 開始:此作業會在從快照集資料庫或靜止資料庫進行初始載入時使用。 系統會在初始載入封裝中的任何時間點叫用此作業。 此作業所接受的參數可以是快照集 LSN、快照集資料庫的名稱 (從中自動衍生快照集 LSN),也可以保留空白 (在此情況中,目前資料庫 LSN 就會當做變更處理封裝的啟始 LSN 使用)。

    此作業是用來取代「標記初始載入開始/結束」作業。

    如果您在 SQL Server CDC (亦即非 Oracle) 上工作時選取了 [標記 CDC 開始],則連線管理員中指定的使用者就必須是 db_owner系統管理員 (sysadmin)

  • 取得處理範圍:此作業是在叫用使用 CDC 來源資料流程的資料流程之前用於變更處理封裝中。 叫用此作業時,它會建立 CDC 來源資料流程所讀取的 LSN 範圍。 此範圍會儲存在資料流程處理期間 CDC 來源所使用的 SSIS 封裝變數中。

    如需儲存之可能 CDC 狀態的詳細資訊,請參閱 定義狀態變數

  • 標記處理的範圍:此作業是在 CDC 回合結束時 (CDC 資料流程順利完成之後) 用以變更處理中的套件,以記錄 CDC 回合中完整處理的最後一個 LSN。 下次執行 GetProcessingRange 時,這個位置就會決定下一個處理範圍的開頭。

  • 重設 CDC 狀態:此作業是用來重設與目前 CDC 內容相關聯的持續性 CDC 狀態。 執行此作業之後,LSN 時間戳記 sys.fn_cdc_get_max_lsn 資料表中的目前最大 LSN 就會變成下一個處理範圍的範圍開頭。 此作業需要來源資料庫的連接。

    此作業使用時機的範例如下:當您只想要處理新建立的變更記錄,而忽略所有舊的變更記錄時。

包含 CDC 狀態的變數
選取儲存工作作業之狀態資訊的 SSIS 封裝變數。 您應該在開始之前定義變數。 如果您選取 [自動狀態持續性],系統就會自動載入並儲存狀態變數。

如需定義狀態變數的詳細資訊,請參閱 定義狀態變數

要啟動 CDC 的 SQL Server LSN/快照集名稱:
輸入目前的來源資料庫 LSN 或從中執行初始載入以決定 CDC 啟動位置之快照集資料庫的名稱。 只有當 [CDC 控制作業] 設定為 [標記 CDC 開始]時,才能使用這個選項。

如需有關這些作業的詳細資訊,請參閱< CDC Control Task>。

自動在資料庫資料表中儲存狀態
選取此核取方塊,可讓 CDC 控制工作自動在指定資料庫所包含的狀態資料表中載入並儲存 CDC 狀態。 如果沒有選取此選項,開發人員就必須在封裝啟動時載入 CDC 狀態,而且每次 CDC 狀態變更時都必須儲存狀態。

儲存狀態之資料庫的連接管理員
從清單中選取現有的 ADO.NET 連接管理員,或按一下 [新增] 建立新的連接。 這會連線到包含 State 資料表的 SQL Server 資料庫。 狀態資料表包含狀態資訊。

只有當您已選取 [自動狀態持續性] 時,才能使用這個選項,而且它是必要參數。

要用於儲存狀態的資料表
輸入要用於儲存 CDC 狀態之狀態資料表的名稱。 指定的資料表必須具有兩個名為 namestate 的資料行,而且這兩個資料行的資料類型都必須是 varchar (256)

您可以選擇性地選取 [ 新增 ] 以取得 SQL 腳本,以建置具有必要數據行的新 State 數據表。 選取 [自動狀態持續性] 時,開發人員必須根據上述需求建立狀態資料表。

只有當您已選取 [自動狀態持續性] 時,才能使用這個選項,而且它是必要參數。

狀態名稱
輸入要與持續性 CDC 狀態產生關聯的名稱。 使用相同 CDC 內容的完整載入和 CDC 封裝都將指定一般狀態名稱。 這個名稱是用於查閱狀態資料表中的狀態資料列。