เริ่มต้นใช้งานด้วยมุมมองทะเลสาบที่เป็นภาพเป็นภาพ

ในการเริ่มต้นอย่างรวดเร็วนี้ คุณจะสร้างตารางต้นทางในบ้านพักริมทะเลสาบใน Microsoft Fabric กําหนดมุมมองทะเลสาบที่สร้างขึ้นจริงเพื่อแปลงข้อมูลดิบผ่านขั้นตอนที่ก้าวหน้า และตั้งตารางรีเฟรช ในตอนท้าย คุณจะมีไปป์ไลน์บรอนซ์สู่ทองคําที่ทํางานได้อย่างสมบูรณ์พร้อมการประสานงานที่ตระหนักถึงการพึ่งพาและการติดตามเชื้อสาย

ข้อกําหนดเบื้องต้น

• พื้นที่ทํางาน ที่มี ความจุ ที่เปิดใช้งาน Fabric
• เลคเฮาส์ที่เปิดใช้งานสคีมาเลคเฮาส์และรันไทม์ผ้า 1.3

สร้างมุมมองทะเลสาบที่เป็นภาพแรกของคุณ

1. ไปที่ พอร์ทัล Fabric และนําทางไปยังพื้นที่ทํางานของคุณ

2. เปิดเลคเฮาส์ของคุณแล้วเลือกวิวทะเลสาบที่เป็นรูปธรรม

   

3. เลือก สมุด>บันทึก>ใหม่สร้างด้วย Spark SQL หรือคุณสามารถเลือก เปิดสมุดบันทึก จากพื้นที่ทํางานหลัก

   

   สมุดบันทึกใหม่จะเปิดขึ้นพร้อมกับเทมเพลตเพื่อสร้างมุมมองทะเลสาบที่เป็นรูปธรรม

   Note

   หากคุณใช้ตารางในคลังสินค้าเป็นแหล่งที่มาของภาพวิวทะเลสาบที่สร้างขึ้นจริง คุณต้องสร้างทางลัดตารางในบ้านพักริมทะเลสาบของคุณ

4. สร้างตารางproductsต้นทางและorders ป้อนคําสั่ง SQL ต่อไปนี้ลงในเซลล์สมุดบันทึกที่มีอยู่และเรียกใช้:

   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. รีเฟรช explorer เพื่อดูตารางที่สร้างขึ้น products ใหม่และ orders ตารางภายใต้ bronze Schema เลือก + รหัส เพื่อเพิ่มเซลล์ใหม่ใต้เซลล์ที่มีอยู่

   

6. เปิดใช้งานฟีดข้อมูลการเปลี่ยนแปลง (CDF) บนตารางต้นทาง เพื่อให้การ รีเฟรชที่เหมาะสมที่สุดสามารถใช้การประมวลผลแบบเพิ่มหน่วยได้ คัดลอกคําสั่ง SQL ต่อไปนี้ลงในเซลล์ใหม่และเรียกใช้:

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

   เลือก + รหัส เพื่อเพิ่มเซลล์ใหม่อีกเซลล์หนึ่ง

7. สร้างมุมมองทะเลสาบที่เป็นรูปธรรมจากตารางต้นทาง คัดลอกคําสั่ง SQL ต่อไปนี้ลงในเซลล์ใหม่และเรียกใช้:

   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. รีเฟรชนักสํารวจ Lakehouse เพื่อดูมุมมอง cleaned_order_data ทะเลสาบที่สร้างขึ้นใหม่และ product_sales_summary ภายใต้ silver สคีมา และ gold ตามลําดับ

   

9. คุณสามารถตรวจสอบผลลัพธ์เพิ่มเติมได้โดยการสืบค้นมุมมองทะเลสาบสีทอง คัดลอกคําสั่ง SQL ต่อไปนี้ลงในเซลล์ใหม่และเรียกใช้:

   SELECT * FROM gold.product_sales_summary;
   

   ผลลัพธ์จะแสดงสามแถว — หนึ่งแถวสําหรับแต่ละผลิตภัณฑ์ — พร้อมปริมาณรวมที่ขาย รายได้รวม และมูลค่าการสั่งซื้อเฉลี่ยที่คํานวณจากข้อมูลคําสั่งซื้อต้นทาง

10. ปิดสมุดบันทึกและกลับไปที่เลคเฮาส์ของคุณ เลือก มุมมองทะเลสาบที่เป็นรูปธรรม แล้วเลือก จัดการ คุณอาจต้องเลือกไอคอนรีเฟรชเพื่อดูสายข้อมูลที่สร้างขึ้นโดยอัตโนมัติ

    

11. จัดกําหนดการการดําเนินการสายข้อมูล เลือก จัดการกําหนดการ จาก Ribbon ในบานหน้าต่าง จัดการกําหนดการ ให้เลือกปุ่ม กําหนดการใหม่ เพื่อสร้างกําหนดการ หมุนปุ่มตัวเลือกสําหรับ กําหนดการรีเฟรช เป็น สถานะเปิด

    

12. เลือกมุมมองที่เป็นรูปธรรมที่จะรีเฟรชเลือก ชนิดการรีเฟรชที่ต้องการกําหนดค่าการตั้งค่าที่จะใช้สําหรับการรีเฟรชและบันทึก

    

13. ไปที่หน้า การเรียกใช้ล่าสุด เพื่อดูความคืบหน้าของการดําเนินการสายข้อมูล

    

14. เลือกการเรียกใช้อย่างต่อเนื่องเพื่อติดตามความคืบหน้า

    

15. เมื่อการรันเสร็จสิ้น สถานะสายข้อมูลจะได้รับการอัปเดต

    

สิ่งที่จะเกิดขึ้นต่อไป

เมื่อคุณมีการรีเฟรชสายข้อมูลตามกําหนดการแล้ว Fabric จะอัปเดตมุมมองทะเลสาบที่เป็นรูปธรรมของคุณโดยอัตโนมัติเมื่อมีการเปลี่ยนแปลงข้อมูลต้นทาง เมื่อมีการแทรกแถวใหม่ลงใน bronze.orders ตาราง หรือ bronze.products การเรียกใช้ตามกําหนดการถัดไปจะตรวจพบการเปลี่ยนแปลง รี silver.cleaned_order_data เฟรชมุมมองก่อน (เนื่องจากมุมมองสีทองขึ้นอยู่กับ) แล้วรีเฟรช gold.product_sales_summary ด้วยผลรวมที่อัปเดต คุณไม่จําเป็นต้องจัดการลําดับการรีเฟรชหรือเขียนตรรกะการประสานรวม — Fabric จะจัดการตามกราฟสายข้อมูล

หากต้องการเรียนรู้เพิ่มเติมเกี่ยวกับพฤติกรรมการรีเฟรชและวิธีที่ Fabric กําหนดกลยุทธ์ที่เหมาะสมที่สุด (ส่วนเพิ่ม แบบเต็ม หรือข้าม) โปรดดู การรีเฟรชที่เหมาะสมที่สุดสําหรับมุมมองทะเลสาบที่เป็นรูปธรรมใน Lakehouse สําหรับคําแนะนําแบบ end-to-end ที่สมบูรณ์ซึ่งแสดงให้เห็นถึงแนวคิดเหล่านี้ด้วยชุดข้อมูลที่ใหญ่ขึ้น โปรดดู บทช่วยสอน: ใช้สถาปัตยกรรมเหรียญด้วยมุมมองทะเลสาบที่เป็นรูปธรรม

เนื้อหาที่เกี่ยวข้อง

• วิวทะเลสาบที่สร้างขึ้นใน Fabric คืออะไร?
• การอ้างอิง Spark SQL สําหรับมุมมองทะเลสาบที่เป็นรูปธรรม
• การรีเฟรชที่เหมาะสมที่สุดสําหรับมุมมองทะเลสาบที่เป็นรูปธรรม