เพิ่มแหล่งข้อมูลฐานข้อมูลมิเรอร์ (ฟีดการเปลี่ยนแปลง) ลงในสตรีมเหตุการณ์

บทความนี้แสดงวิธีการเพิ่มแหล่งข้อมูลฐานข้อมูลมิเรอร์ (ตัวดึงข้อมูลการเปลี่ยนแปลง) ลงในสตรีมเหตุการณ์

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

ตัวเชื่อมต่อนี้รองรับฐานข้อมูลมิเรอร์ทุกประเภทที่มีอยู่ใน Fabric Mirroring รวมถึง:

  • ฐานข้อมูล Azure SQL
  • Azure Cosmos DB
  • Snowflake
  • เปิดมิเรอร์

Note

ตัวเชื่อมต่อนี้อยู่ในการแสดงตัวอย่าง ตัวเชื่อมต่อนําเข้าเหตุการณ์ฟีดการเปลี่ยนแปลงดิบจากฐานข้อมูลมิเรอร์ DeltaFlow (การแปลงเหตุการณ์ที่พร้อมสําหรับการวิเคราะห์) ไม่ได้รับการสนับสนุนด้วยตัวเชื่อมต่อนี้ในขณะนี้

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

เปิดใช้ตัวช่วยสร้าง Connect แหล่งข้อมูล

หากคุณยังไม่ได้เพิ่มแหล่งข้อมูลใดๆ ลงในสตรีมเหตุการณ์ของคุณ ให้เลือกไทล์ เชื่อมต่อแหล่งข้อมูล คุณยังสามารถเลือก เพิ่มแหล่งข้อมูล>Connect บนริบบิ้นได้อีกด้วย

สกรีนช็อตที่แสดงการเลือกไทล์สําหรับการใช้แหล่งข้อมูลภายนอก

หากคุณกําลังเพิ่มแหล่งที่มาไปยังสตรีมเหตุการณ์ที่เผยแพร่แล้ว ให้เปลี่ยนเป็นโหมดแก้ไข บน Ribbon ให้เลือก เพิ่มแหล่งข้อมูล Connect>

สกรีนช็อตที่แสดงการเลือกสําหรับการเพิ่มแหล่งข้อมูลภายนอก

บนหน้า เลือกแหล่งข้อมูล ให้ค้นหา ฐานข้อมูลมิเรอร์ แล้วเลือก เชื่อมต่อ บนไทล์ ฐานข้อมูลมิเรอร์ (เปลี่ยนฟีด)

สกรีนช็อตที่แสดงการเลือกฐานข้อมูลมิเรอร์ (ตัวดึงข้อมูลการเปลี่ยนแปลง) เป็นชนิดแหล่งข้อมูลในตัวช่วยสร้าง รับเหตุการณ์

กําหนดค่าและเชื่อมต่อกับฟีดการเปลี่ยนแปลงฐานข้อมูลมิเรอร์

นําเข้าเหตุการณ์ฟีดการเปลี่ยนแปลงลงใน Eventstream จากฐานข้อมูล Fabric Mirrored ที่คุณเลือก

  1. บนหน้า เชื่อมต่อ ให้เลือกฐานข้อมูลมิเรอร์ที่จะเชื่อมต่อ

    1. สําหรับ Workspace ให้เรียกดูและเลือกพื้นที่ทํางาน Fabric ที่มีฐานข้อมูลมิเรอร์

    2. สําหรับ ฐานข้อมูลมิเรอร์ ให้เลือกฐานข้อมูลมิเรอร์จากรายการฐานข้อมูลที่พร้อมใช้งานในพื้นที่ทํางานที่เลือก

      สกรีนช็อตที่แสดงพื้นที่ทํางานและตัวเลือกฐานข้อมูลมิเรอร์บนหน้า เชื่อมต่อ

  2. เลือก ตารางทั้งหมด หรือ ป้อนชื่อตาราง เพื่อระบุตารางที่จะตรวจสอบการเปลี่ยนแปลง หากคุณเลือกรายการหลัง ให้ระบุตารางโดยใช้รายการตัวระบุตารางที่คั่นด้วยเครื่องหมายจุลภาค (schemaName.tableName) หรือนิพจน์ปกติที่ถูกต้อง เช่น:

    • ใช้ dbo.Orders.* เพื่อเลือกตารางทั้งหมดที่มีชื่อเริ่มต้นด้วย dbo.Orders
    • ใช้ dbo\.(Orders|Customers) เพื่อเลือก dbo.Orders และ dbo.Customers

    คุณสามารถผสมรูปแบบทั้งสองได้โดยใช้เครื่องหมายจุลภาค ขีดจํากัดอักขระทั้งหมดสําหรับรายการทั้งหมดคือ 102,400 อักขระ

    Note

    ในรุ่นตัวอย่างปัจจุบัน เฉพาะตัวเลือก ตารางทั้งหมด เท่านั้นที่พร้อมใช้งาน

  3. บนหน้า ตรวจทาน + เชื่อมต่อ ให้ตรวจทานสรุปการตั้งค่า แล้วเลือก เพิ่ม

    สกรีนช็อตที่แสดงหน้า ตรวจทาน + เชื่อมต่อ สําหรับแหล่งข้อมูลฟีดการเปลี่ยนแปลงฐานข้อมูลที่มิเรอร์

  4. คุณสามารถดูแหล่งที่มาของฐานข้อมูลมิเรอร์ (ฟีดการเปลี่ยนแปลง) ที่เพิ่มลงในสตรีมเหตุการณ์ของคุณในขณะที่ยังอยู่ในโหมดแก้ไข

ดูเหตุการณ์ที่อัปเดตแล้ว

  1. เมื่อต้องการใช้แหล่งข้อมูลฐานข้อมูลมิเรอร์ (ฟีดการเปลี่ยนแปลง) ที่เพิ่มเข้ามาใหม่ ให้เลือก เผยแพร่ หลังจากที่คุณทําตามขั้นตอนเหล่านี้เสร็จแล้ว แหล่งที่มาของฐานข้อมูลมิเรอร์ (ตัวดึงข้อมูลการเปลี่ยนแปลง) ของคุณจะพร้อมใช้งานสําหรับการแสดงภาพในมุมมองสด

    สกรีนช็อตของการสตรีม Mirrored Database Change Feed source ในมุมมองสด

กําหนดค่าปลายทาง Eventstream เพื่อใช้สคีมา

ปัจจุบัน เฉพาะ Eventhouse, ปลายทางที่กําหนดเอง และปลายทางสตรีมที่ได้รับเท่านั้นที่รองรับสําหรับ Eventstreams ที่มี Schema ที่เกี่ยวข้อง ส่วนนี้แสดงวิธีเพิ่มและกําหนดค่าปลายทาง Eventhouse เมื่อเปิดใช้งานคุณลักษณะเพิ่มเติม (เช่น การสนับสนุน Schema) สําหรับสตรีมเหตุการณ์

Note

เมื่อคุณใช้ DeltaFlow (พรีวิว) กับแหล่งข้อมูลการบันทึกข้อมูลการเปลี่ยนแปลง (CDC) ที่รองรับ ตารางปลายทางใน Eventhouse จะถูกสร้างขึ้นโดยอัตโนมัติและจัดการให้ตรงกับโครงสร้างตารางต้นทาง คุณไม่จําเป็นต้องกําหนดค่า Schema ตารางปลายทางด้วยตนเอง DeltaFlow ยังจัดการวิวัฒนาการสคีมาโดยอัตโนมัติเมื่อตารางต้นทางเปลี่ยนไป

กําหนดค่า Schema สําหรับปลายทางปลายทางแบบกําหนดเอง

  1. เลือก แปลงเหตุการณ์ หรือ เพิ่มปลายทาง แล้วเลือก CustomEndpoint

  2. บนบานหน้าต่าง ปลายทางแบบกําหนดเอง ให้ระบุชื่อสําหรับปลายทาง

  3. สําหรับ Schema อินพุต ให้เลือก Schema สําหรับเหตุการณ์ คุณทําการเลือกในกล่องนี้เมื่อคุณเปิดใช้งานการสนับสนุน Schema สําหรับสตรีมเหตุการณ์

สกรีนช็อตที่แสดงบานหน้าต่างสําหรับการกําหนดค่าจุดสิ้นสุดแบบกําหนดเอง

สําหรับขั้นตอนโดยละเอียดเกี่ยวกับการกําหนดค่าปลายทางปลายทางแบบกําหนดเอง โปรดดู เพิ่มปลายทางที่กําหนดเองหรือปลายทางแอปแบบกําหนดเองไปยังสตรีมเหตุการณ์

กําหนดค่า Schema สําหรับปลายทางของบ้านเหตุการณ์

  1. เลือก แปลงเหตุการณ์ หรือ เพิ่มปลายทาง แล้วเลือก Eventhouse

  2. บนบานหน้าต่าง Eventhouse ให้กําหนดค่าการตั้งค่าที่เกี่ยวข้องกับ Schema ต่อไปนี้:

    1. สําหรับ Schema อินพุต ให้เลือก Schema อย่างน้อยหนึ่งรายการจากรายการดรอปดาวน์

      สกรีนช็อตที่แสดงบานหน้าต่างการกําหนดค่า eventhouse ที่มี Schema อินพุตที่เลือกไว้

      Note

      ถ้าคุณเลือกตัวเลือก สคีมาแบบไดนามิกผ่านส่วนหัว เมื่อกําหนดค่าแหล่งข้อมูลฮับเหตุการณ์ คุณอาจได้กําหนดค่า Schema หลายรายการสําหรับแหล่งข้อมูล และแม็ปกับคุณสมบัติต่างๆ และค่าของต้นทาง

    2. สําหรับ วิธีการสร้างตาราง ให้เลือกตาราง เดียวที่มีสคีมาทั้งหมดรวม กัน หรือ แยกตารางสําหรับแต่ละสคีมา ขึ้นอยู่กับความต้องการของคุณ

      สกรีนช็อตที่แสดงบานหน้าต่างการกําหนดค่า eventhouse พร้อมวิธีการสร้างตาราง

    3. สําหรับ เขียนข้อมูลด้วย ให้เลือกหนึ่งในตัวเลือกต่อไปนี้:

      • เพย์โหลดเท่านั้น: เขียนข้อมูลเพย์โหลดที่แยกออกมาไปยังตาราง หากมีสคีมาอินพุตหลายรายการ ข้อมูลจะถูกส่งไปยังหลายตาราง
      • ข้อมูลเมตาและเพย์โหลด: เขียนข้อมูลเมตาและข้อมูลเพย์โหลดลงในตารางเดียว คอลัมน์ตัวอย่าง ได้แก่ source , subject, , typeและdata

      สกรีนช็อตที่แสดงบานหน้าต่างการกําหนดค่า eventhouse พร้อมตัวเลือกสําหรับการเขียนข้อมูล

สําหรับขั้นตอนโดยละเอียดเกี่ยวกับการกําหนดค่าปลายทางของบ้านเหตุการณ์ โปรดดู เพิ่มปลายทางของบ้านเหตุการณ์ไปยังสตรีมเหตุการณ์

ตัวเชื่อมต่ออื่นๆ: