Crea una Stored Procedure per la registrazione nel Warehouse

Creiamo una Stored Procedure che definisca quali dettagli del log acquisire e la tabella in cui salvarli.

Apri il warehouse che hai creato e, dal menu in alto, seleziona New SQL query.
Esegui il seguente codice SQL per creare la Stored Procedure e verifica la sua creazione dalla scheda Explorer.

(Dedica un momento a leggere il codice SQL qui sotto. I commenti ti guidano in ogni parte per una migliore comprensione.)

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;

Spiegazione del codice: questa Stored Procedure verifica innanzitutto se la tabella PipelineLogs esiste e, in caso contrario, la crea. Poi inserisce in questa tabella i dettagli dell'esecuzione della pipeline. I dettagli del log sono impostati come parametri nella Stored Procedure e passeremo questi valori dalla pipeline nei prossimi passaggi.

Portare dati in Fabric con le Pipeline

Acquisizione dei dati e modelli semantici con Microsoft Fabric

esercizio interattivo pratico