แชร์ผ่าน

ใช้โน้ตบุ๊ค Fabric ที่มีข้อมูลจากฐานข้อมูล KQL

  • บทความ

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

มีสองวิธีในการใช้โน้ตบุ๊ค Fabric ที่มีข้อมูลจากฐานข้อมูล KQL ของคุณ:

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

  • พื้นที่ทํางานที่มีความจุที่เปิดใช้งาน Microsoft Fabric
  • ฐานข้อมูล KQL ที่มีสิทธิ์การดูเป็นอย่างน้อย

ใช้ส่วนย่อย Kusto ในสมุดบันทึก

สมุดบันทึกผ้ามี ส่วนย่อย ของโค้ดที่ช่วยให้คุณเขียนรูปแบบโค้ดที่ใช้บ่อยได้อย่างง่ายดาย คุณสามารถใช้ส่วนย่อยในการเขียนหรืออ่านข้อมูลในฐานข้อมูล KQL โดยใช้ KQL

  1. นําทางไปยังสมุดบันทึกที่มีอยู่ หรือสร้างขึ้นใหม่

  2. ในเซลล์โค้ด เริ่มพิมพ์ kusto

    การจับภาพหน้าจอของการใช้ส่วนย่อย Kusto เพื่อใช้ KQL ในสมุดบันทึก Fabric

  3. เลือกส่วนย่อยที่สอดคล้องกับการดําเนินการที่คุณต้องการดําเนินการ: เขียนข้อมูลไปยังฐานข้อมูล KQL หรือ อ่านข้อมูลจากฐานข้อมูล KQL

    ส่วนย่อยของโค้ดต่อไปนี้แสดงการดําเนินการอ่านข้อมูลตัวอย่าง:

    # Example of query for reading data from Kusto. Replace T with your <tablename>.
kustoQuery = "['T'] | take 10"
# The query URI for reading the data e.g. https://<>.kusto.data.microsoft.com.
kustoUri = "https://<yourKQLdatabaseURI>.z0.kusto.data.microsoft.com"
# The database with data to be read.
database = "DocsDatabase"
# The access credentials.
accessToken = mssparkutils.credentials.getToken(kustoUri)
kustoDf  = spark.read\
    .format("com.microsoft.kusto.spark.synapse.datasource")\
    .option("accessToken", accessToken)\
    .option("kustoCluster", kustoUri)\
    .option("kustoDatabase", database)\
    .option("kustoQuery", kustoQuery).load()

# Example that uses the result data frame.
kustoDf.show()

    ส่วนย่อยของโค้ดต่อไปนี้แสดงตัวอย่างการเขียนข้อมูล:

    # The Kusto cluster uri to write the data. The query Uri is of the form https://<>.kusto.data.microsoft.com 
kustoUri = ""
# The database to write the data
database = ""
# The table to write the data 
table    = ""
# The access credentials for the write
accessToken = mssparkutils.credentials.getToken(kustoUri)

# Generate a range of 5 rows with Id's 5 to 9
data = spark.range(5,10) 

# Write data to a Kusto table
data.write.\
format("com.microsoft.kusto.spark.synapse.datasource").\
option("kustoCluster",kustoUri).\
option("kustoDatabase",database).\
option("kustoTable", table).\
option("accessToken", accessToken ).\
option("tableCreateOptions", "CreateIfNotExist").mode("Append").save()

  4. ใส่ข้อมูลที่จําเป็นภายในเครื่องหมายอัญคมของแต่ละเขตข้อมูลในเซลล์ข้อมูล:

    เขตข้อมูล คำอธิบาย ลิงก์ที่เกี่ยวข้อง
    kustoQuery คิวรี KQL ที่จะประเมิน ภาพรวม KQL
    KustoUri คิวรี URI ของฐานข้อมูล KQL ของคุณ คัดลอก URI ฐานข้อมูล KQL
    ฐานข้อมูล ชื่อของฐานข้อมูล KQL ของคุณ เข้าถึงฐานข้อมูล KQL ที่มีอยู่
    ข้อมูล ข้อมูลที่จะเขียนลงในตาราง

  5. เรียกใช้เซลล์โค้ด

สร้างสมุดบันทึกจากฐานข้อมูล KQL

เมื่อคุณสร้างสมุดบันทึกเป็นรายการที่เกี่ยวข้องในฐานข้อมูล KQL สมุดบันทึกจะได้รับชื่อเดียวกันกับฐานข้อมูล KQL และมีข้อมูลการเชื่อมต่อไว้ล่วงหน้า

  1. เรียกดูฐานข้อมูล KQL ของคุณ

  2. เลือก สร้างรายการ>ที่เกี่ยวข้องสมุดบันทึก

    สกรีนช็อตของการสร้างสมุดบันทึกเป็นรายการที่เกี่ยวข้องในฐานข้อมูล KQL

    สมุดบันทึกถูกสร้างขึ้นด้วย KustoUri และมีรายละเอียดฐานข้อมูลไว้ล่วงหน้า

  3. ใส่คิวรี KQL ที่จะประเมินในเขตข้อมูล kustoQuery

    ภาพหน้าจอของสมุดบันทึกที่สร้างขึ้นจากฐานข้อมูล KQL

  4. เรียกใช้เซลล์โค้ด

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