Rozpocznij pracę z zmaterializowanymi widokami jeziora

Z tego artykułu dowiesz się, jak rozpocząć pracę z zmaterializowanymi widokami jeziora, tworząc je w usłudze Microsoft Fabric lakehouse.

Wymagania wstępne

• Obszar roboczy z pojemnością obsługiwaną przez Microsoft Fabric.
• System lakehouse ze schematami lakehouse włączonymi.
• Fabryczne środowisko uruchomieniowe 1.3. Zmaterializowane widoki lake są zgodne z tą wersją środowiska uruchomieniowego.

Tworzenie pierwszego zmaterializowanego widoku jeziora

1. Przejdź do jeziora i wybierz pozycję Zarządzaj zmaterializowanymi widokami jeziora.

   

2. Wybierz pozycję Nowy zmaterializowany widok jeziora, a następnie wybierz pozycję Nowy notes.

   

   Otwiera się nowy notes.

   

3. Utwórz przykładowe tabele products źródłowe i orders. Uruchom następujące polecenia w notesie:

      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');
   

4. Utwórz zmaterializowane widoki lake przy użyciu tabel źródłowych. Uruchom następujące polecenia w notesie:

      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;
   

5. Otwórz eksploratora lakehouse, aby wyświetlić wszystkie utworzone tabele i zmaterializowane widoki jeziora.

   

6. W swoim lakehouse przejdź do pozycji Zarządzaj zmaterializowanymi widokami lakehouse, aby wyświetlić automatycznie wygenerowaną linię pochodzenia.

   

7. Zaplanuj wykonywanie linii danych.

   

8. Wybierz bieżące zadanie, aby monitorować postęp po rozpoczęciu realizacji harmonogramu.

   

9. Po pomyślnym zakończeniu przebiegu status linii to Zakończono.

   

Treści powiązane

• Dokumentacja języka Spark SQL dla zmaterializowanych widoków lake
• Odśwież zmaterializowane widoki na jezioro w jeziorze