在 Warehouse 中建立用於記錄的預存程序

我們來建立一個預存程序，用來定義要擷取哪些記錄細節，並指定要將這些細節寫入哪個資料表。

開啟你剛建立的 warehouse，並從上方選單選擇 New SQL query。
執行下列 SQL 程式碼以建立預存程序，並從 Explorer 分頁驗證其是否建立成功。

（花點時間閱讀下方的 SQL 程式碼。已提供註解，協助你逐段理解內容。）

CREATE PROCEDURE LogPipelineRun
    @PipelineName     VARCHAR(100),  -- Name of the pipeline being logged
    @RunId            VARCHAR(100),  -- Unique identifier for the pipeline run
    @ExecutionStatus  VARCHAR(50)    -- Status of the pipeline execution 
AS
BEGIN
    -- Check if the PipelineLogs table exists, create it if it doesn't
    IF NOT EXISTS (SELECT * FROM sys.tables WHERE name = 'PipelineLogs')
    BEGIN
        CREATE TABLE PipelineLogs (
            PipelineName     VARCHAR(100),  -- Name of the pipeline
            RunId            VARCHAR(100),  -- Identifier for the pipeline run
            ExecutionStatus  VARCHAR(50)    -- Status of the pipeline execution
        );
    END;

    -- Insert the pipeline run details into the PipelineLogs table
    INSERT INTO PipelineLogs (PipelineName, RunId, ExecutionStatus)
    VALUES (@PipelineName, @RunId, @ExecutionStatus);
END;

程式碼說明： 這個預存程序會先檢查是否已存在 PipelineLogs 資料表；若沒有就建立。接著，將管線執行的細節插入到該表。記錄細節以參數形式在預存程序中定義，而你將在下一步從管線傳入這些參數值。

實作排程執行的 Pipeline

Microsoft Fabric 的資料擷取與語意模型

動手互動練習