Kom i gang med materialiserede visninger af søen

I denne quickstart opretter du kildetabeller i et lakehouse i Microsoft Fabric, definerer materialiserede lake-visninger for at transformere rådata gennem progressive faser og opsætter opdateringsplaner. Til sidst har du en fuldt fungerende bronze-til-guld-pipeline med afhængighedsbevidst orkestrering og linjesporing.

Forudsætninger

Opret din første materialiserede søvisning

  1. Gå til Fabric-portalen og navigér til dit arbejdsområde.

  2. Åbn dit søhus og vælg Materialiserede søudsigter.

    Skærmbillede, der viser menupunktet til styring af materialiserede søvisninger.

  3. Vælg Ny>Ny notesbog>:Opret med Spark SQL. Alternativt kan du vælge Åbn notesbog fra hovedlærredet.

    Skærmbillede af valg til åbning af en ny notesbog for at oprette en materialiseret søvisning.

    En ny notesbog åbner med en skabelon til at skabe en materialiseret søudsigt.

    Bemærkning

    Hvis du bruger et bord i et lager som kilde til et materialiseret søudsyn, skal du lave en genvej til en tabel i dit søhus.

  4. Opret kildetabellerne products og orders. Indtast følgende SQL-kommando i den eksisterende notesbogscelle og kør den:

    CREATE SCHEMA IF NOT EXISTS bronze;

CREATE TABLE IF NOT EXISTS bronze.products (
   product_id INT,
   product_name STRING,
   price DOUBLE
);

INSERT INTO bronze.products VALUES
(101, 'Laptop', 1200.50),
(102, 'Smartphone', 699.99),
(103, 'Tablet', 450.00);

CREATE TABLE IF NOT EXISTS bronze.orders (
   order_id INT,
   product_id INT,
   quantity INT,
   order_date DATE
   );

INSERT INTO bronze.orders VALUES
   (1001, 101, 2, '2025-06-01'),
   (1002, 103, 1, '2025-06-02'),
   (1003, 102, 3, '2025-06-03');

  5. Opdater exploreren for at se de nyoprettede products tabeller under orders skemaet bronze . Vælg + Code for at tilføje en ny celle under den eksisterende.

    Skærmbillede, der viser kildetabeller oprettet i et Lakehouse.

  6. Aktivér change data feed (CDF) på kildetabellerne, så optimal opdatering kan bruge inkrementel behandling. Kopier følgende SQL-kommando ind i den nye celle og kør den:

    ALTER TABLE bronze.products SET TBLPROPERTIES (delta.enableChangeDataFeed = true);
ALTER TABLE bronze.orders SET TBLPROPERTIES (delta.enableChangeDataFeed = true);

    Vælg + Kod for at tilføje endnu en ny celle.

  7. Skab materialiserede søudsigter fra kildetabellerne. Kopier følgende SQL-kommando ind i den nye celle og kør den:

    CREATE SCHEMA IF NOT EXISTS silver;

CREATE MATERIALIZED LAKE VIEW IF NOT EXISTS silver.cleaned_order_data AS
SELECT 
   o.order_id,
   o.order_date,
   o.product_id,
   p.product_name,
   o.quantity,
   p.price,
   o.quantity * p.price AS revenue
FROM bronze.orders o
JOIN bronze.products p
ON o.product_id = p.product_id;

CREATE SCHEMA IF NOT EXISTS GOLD;

CREATE MATERIALIZED LAKE VIEW IF NOT EXISTS gold.product_sales_summary AS
SELECT
   product_id,
   product_name,
   SUM(quantity) AS total_quantity_sold,
   SUM(revenue) AS total_revenue,
   ROUND(AVG(revenue), 2) AS average_order_value
FROM
   silver.cleaned_order_data
GROUP BY
   product_id,
   product_name;

  8. Opdater Lakehouse Explorer for at se de nyligt skabte materialiserede søudsigter cleaned_order_data og product_sales_summary under silver og gold skemaerne, henholdsvis.

    Skærmbillede, der viser materialiserede søudsigter skabt i et søhus.

  9. Du kan yderligere verificere resultaterne ved at forespørge det guldmaterialiserede søsyn. Kopier følgende SQL-kommando ind i en ny celle og kør den:

    SELECT * FROM gold.product_sales_summary;

    Outputtet viser tre rækker — én for hvert produkt — hvor den samlede solgte mængde, den samlede omsætning og den gennemsnitlige ordreværdi er beregnet ud fra kildeordredataene.

  10. Luk notesbogen og tag tilbage til dit sommerhus ved Lake. Vælg Materialiserede søudsigter og vælg Administrér. Du skal måske vælge opdateringsikonet for at se den autogenererede slægtslinje.

    Skærmbillede, der viser afstamning.

  11. Planlæg udførelse af afstamning. Vælg Administrer tidsplaner fra båndet. I panelet Administrer tidsplaner skal du vælge knappen Ny tidsplan for at oprette en tidsplan. Drej radioknappen for at genopfriske planen til Tændt-tilstand .

    Skærmbillede af ruden til planlægning af afstamning.

  12. Vælg de materialiserede visninger, der skal opdateres, vælg den ønskede opdateringstype, konfigurer indstillingerne til opdatering og gem den.

    Skærmbillede af panelet for planlægning af slægtslinje med flere muligheder.

  13. Gå til siden for nylig gennemløb for at se fremskridtet med slægtsudførelsen.

    Skærmbillede, der viser den seneste gennemspilning.

  14. Vælg et igangværende gennemløb for at følge dets fremskridt.

    Skærmbillede, der viser status for en igangværende kørsel.

  15. Når kørslen er afsluttet, opdateres slægtsstatus.

    Skærmbillede, der viser en afsluttet afstamning.

Hvad sker der nu?

Nu hvor du har en planlagt linjeopdatering, holder Fabric automatisk dine materialiserede søvisninger opdaterede, efterhånden som kildedata ændres. Når nye rækker indsættes i eller tabellernebronze.orders, registrerer næste planlagte kørsel ændringerne, opdaterer visningen bronze.products først (fordi guldvisningen afhænger af den), og opdaterer silver.cleaned_order_data derefter med de opdaterede totaler.gold.product_sales_summary Du behøver ikke styre opdateringsrækkefølgen eller skrive orkestreringslogik — Fabric håndterer det baseret på lineage-grafen.

For at lære mere om opdateringsadfærd og hvordan Fabric bestemmer den optimale strategi (inkrementell, fuld eller skip), se Optimal opdatering for materialiserede søudsigter i et søhus. For en komplet gennemgang fra ende til ende, der demonstrerer disse koncepter med et større datasæt, se Tutorial: Implementér medaljonarkitektur med materialiserede søudsigter.

Relateret indhold

  • Last updated on