การรวมข้อมูล

การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

Luis Silva

Solution Architect - Data & AI

ควรรวมข้อมูลเมื่อใด?

  • ลดจำนวนแถวในชุดข้อมูลโดยใช้ฟังก์ชันการรวม เพื่อสร้างข้อมูลสรุป
    • นับ
    • สรุป
    • ค่าเฉลี่ย
    • ค่าสูงสุด
    • ค่าต่ำสุด
การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

ควรรวมข้อมูลเมื่อใด?

  • ลดจำนวนแถวในชุดข้อมูลโดยใช้ฟังก์ชันการรวม เพื่อสร้างข้อมูลสรุป
    • นับ
    • สรุป
    • ค่าเฉลี่ย
    • ค่าสูงสุด
    • ค่าต่ำสุด

ตารางคำสั่งซื้อต่อรัฐที่ถูกรวมเป็นตารางใหม่แสดงจำนวนคำสั่งซื้อและยอดขายรวมต่อรัฐ

การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

เครื่องมือสำหรับการรวมข้อมูล

 

 

ไอคอนแสดงสามเครื่องมือ ได้แก่ SQL, Spark และ Dataflows

การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

การรวมข้อมูลด้วย SQL

  • ฟังก์ชันการรวมข้อมูลทั่วไปใน SQL:
    • SUM()
    • COUNT()
    • AVG()
    • MIN()
    • MAX()
  • มักใช้ร่วมกับ GROUP BY
  • ฟังก์ชันทางสถิติ
    • STDEV()
    • VAR()
SELECT
  <unaggregated columns>,
  function(<aggregated column>)
FROM 
  <table>
GROUP BY 
  <unaggregated columns>;
การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

การรวมข้อมูลด้วย SQL

SELECT 
  [State], 
  COUNT([Order_ID]) AS [Num Orders], 
  SUM([Order_Amount]) AS [Total Amount]
FROM 
  [tbl_Orders]
GROUP BY 
  [State]

ตารางคำสั่งซื้อต่อรัฐที่ถูกรวมเป็นตารางใหม่แสดงจำนวนคำสั่งซื้อและยอดขายรวมต่อรัฐ

การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

การรวมข้อมูลด้วย Spark

  • ฟังก์ชันการรวมข้อมูลทั่วไปใน PySpark:
    • sum()
    • count()
    • avg()
    • min() และ max()
    • first() และ last()
  • ฟังก์ชันทางสถิติ
    • stdev()
    • variance()
  • ใช้ร่วมกับ groupBy() และ agg()
df.groupBy(<unaggregated columns>)
.agg(function(<aggregated column>))

การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

การรวมข้อมูลด้วย Spark

ตารางคำสั่งซื้อต่อรัฐที่ถูกรวมเป็นตารางใหม่แสดงจำนวนคำสั่งซื้อและยอดขายรวมต่อรัฐ

from pyspark.sql.functions import sum

df.groupBy("state").agg(count("order_id"), sum("order_amount")).show()
การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

การรวมข้อมูลด้วย Spark

  • ต้องนำเข้าฟังก์ชันการรวมจาก pyspark.sql.functions โดยเพิ่มคำสั่ง import ไว้ที่ต้นโค้ด
#----- Import one or multiple functions:
from pyspark.sql.functions import sum, avg, count, min, max

#----- Import all SQL functions:
from pyspark.sql.functions import * 

#----- Import all SQL functions with an alias:
import pyspark.sql.functions as F
# call sum: F.sum()
การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

การรวมข้อมูลด้วย Dataflows

  • การแปลง Group by
    • Sum
    • Average
    • Median
    • Min
    • Max
    • Percentile
    • Count rows

ภาพหน้าจอกล่องโต้ตอบ Group by ใน Dataflows

การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

การรวมข้อมูลด้วย Dataflows

ภาพหน้าจอกล่องโต้ตอบ Group by ใน Dataflow ที่กำหนดให้จัดกลุ่มตามรัฐ พร้อมการรวมสองรายการ ได้แก่ การนับแถวและผลรวมของคอลัมน์ยอดคำสั่งซื้อ

ตารางคำสั่งซื้อต่อรัฐที่ถูกรวมเป็นตารางใหม่แสดงจำนวนคำสั่งซื้อและยอดขายรวมต่อรัฐ

การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

มาฝึกกันเถอะ!

การแปลงและวิเคราะห์ข้อมูลด้วย Microsoft Fabric

Preparing Video For Download...