在 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 表；若不存在则创建。随后将管道运行的明细插入此表。日志明细在存储过程中以参数形式定义，接下来我们会在管道中传入这些参数值。

实现计划的管道运行

使用 Microsoft Fabric 进行数据摄取与语义模型

动手互动练习