Tạo Stored Procedure để ghi log trong Warehouse

Hãy tạo một Stored Procedure để xác định các chi tiết log cần thu thập và chỉ định bảng nơi sẽ lưu những chi tiết này.

Mở warehouse bạn đã tạo và trên thanh menu phía trên, chọn New SQL query.
Chạy đoạn mã SQL sau để tạo Stored Procedure và xác minh từ thẻ Explorer rằng nó đã được tạo.

(Dành chút thời gian đọc qua đoạn SQL bên dưới. Phần chú thích được cung cấp để hướng dẫn bạn từng phần cho dễ hiểu hơn.)

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;

Giải thích mã: Stored Procedure này trước tiên kiểm tra xem bảng PipelineLogs đã tồn tại chưa và tạo mới nếu chưa có. Sau đó, nó chèn các chi tiết lần chạy pipeline vào bảng. Các chi tiết log được đặt dưới dạng tham số trong Stored Procedure, và ở các bước tiếp theo, bạn sẽ truyền giá trị tham số từ pipeline.

Khám phá các hoạt động trong Data Pipeline

Nạp dữ liệu và Mô hình Ngữ nghĩa với Microsoft Fabric

Bài tập tương tác thực hành