แชร์ผ่าน


เพิ่ม Azure Cosmos DB CDC เป็นแหล่งข้อมูลในฮับแบบเรียลไทม์

บทความนี้อธิบายวิธีการเพิ่ม Azure Cosmos DB สําหรับ NoSQL เปลี่ยนแปลงการจับภาพข้อมูล (CDC) เป็นแหล่งเหตุการณ์ในฮับเวลาจริงของ Fabric

ตัวเชื่อมต่อแหล่งข้อมูล Azure Cosmos DB Change Data Capture (CDC) ช่วยให้คุณจับภาพสแนปช็อตของข้อมูลปัจจุบันในฐานข้อมูล Azure Cosmos DB ตัวเชื่อมต่อจะตรวจสอบและบันทึกการเปลี่ยนแปลงระดับแถวในอนาคตใดก็ตามในข้อมูลนี้ เมื่อการเปลี่ยนแปลงถูกบันทึกไว้ในสตรีม คุณสามารถประมวลผลข้อมูล CDC นี้ในแบบเรียลไทม์ และส่งไปยังปลายทางอื่นภายใน Fabric เพื่อประมวลผลหรือวิเคราะห์เพิ่มเติม

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

  • เข้าถึงพื้นที่ทํางานในโหมดสิทธิ์การใช้งาน Fabric capacity (หรือ) โหมดสิทธิ์การใช้งานรุ่นทดลองใช้ที่มีสิทธิ์ผู้สนับสนุนหรือสูงกว่า
  • เข้าถึง Azure Cosmos DB สําหรับบัญชี NoSQL และฐานข้อมูล
  • ฐานข้อมูล Azure Cosmos DB สําหรับฐานข้อมูล NoSQL ของคุณต้องสามารถเข้าถึงแบบสาธารณะได้และไม่ได้อยู่หลังไฟร์วอลล์หรือมีความปลอดภัยในเครือข่ายเสมือน
  • ถ้าคุณไม่มีเหตุการณ์สตรีม ให้สร้างเหตุการณ์สตรีม

รับรายละเอียดการเชื่อมต่อจากพอร์ทัล Azure

ป้ายชื่อสําหรับรายการที่คุณจําเป็นต้องรวบรวมจากพอร์ทัล Azure จะแสดงในขั้นตอนต่อไปนี้ คุณจําเป็นต้องมี URI จุดสิ้นสุดเสมอในรูปแบบเช่น https://<account>.<api>.azure.com:<port>/คีย์หลัก และชื่อฐานข้อมูลและ ID รายการที่คุณต้องการรวบรวมข้อมูล

หมายเหตุ

Azure Cosmos DB สําหรับ NoSQL CDC กําลังใช้ เวอร์ชัน ล่าสุดของ ตัวดึงข้อมูลการเปลี่ยนแปลง Azure Cosmos DB ซึ่งจะบันทึกการเปลี่ยนแปลงไปยังบันทึกในเวอร์ชันล่าสุด โปรดทราบว่า การลบจะไม่ถูกบันทึกด้วยโหมดนี้

  1. บนหน้าพอร์ทัล Azure สําหรับบัญชี Azure Cosmos DB ของคุณ เลือก คีย์ ภายใต้ การตั้งค่า ในการนําทางด้านซ้าย

  2. บนหน้า คีย์ ให้ คัดลอกค่า URI และ คีย์ หลัก เพื่อใช้สําหรับการตั้งค่าการเชื่อมต่อเหตุการณ์สตรีม

    สกรีนช็อตของคีย์ URI และคีย์หลักบนหน้าคีย์ Azure Cosmos DB ในพอร์ทัล Azure

  3. บนหน้าภาพรวมพอร์ทัล Azure สําหรับบัญชี Azure Cosmos DB ของคุณ ให้สังเกตฐานข้อมูลและ ID รายการที่คุณต้องการรวบรวมข้อมูล

    สกรีนช็อตของรายการคอนเทนเนอร์สําหรับบัญชี Azure Cosmos DB NoSQL API

รับเหตุการณ์จาก Azure Cosmos DB CDC

คุณสามารถรับเหตุการณ์จาก CDC Azure Cosmos DB ลงในฮับเรียลไทม์ด้วยหนึ่งในวิธีต่อไปนี้:

หน้าแหล่งข้อมูล

  1. ลงชื่อเข้าใช้ Microsoft Fabric

  2. เลือก เรียลไทม์ บนแถบนําทางด้านซ้าย

  3. บนหน้า ฮับ เรียลไทม์ เลือก + แหล่งข้อมูล ภายใต้ เชื่อมต่อไปยัง บนเมนูนําทางด้านซ้าย คุณยังสามารถไปที่ หน้า แหล่งข้อมูล จาก หน้า สตรีม ข้อมูลทั้งหมด หรือ สตรีม ข้อมูลของฉัน โดยการเลือก ปุ่ม + เชื่อมต่อแหล่งข้อมูล ที่มุมบนขวา

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

ใช้คําแนะนําจากเพิ่ม Azure Cosmos DB CDC เป็นส่วนแหล่งข้อมูล

หน้าแหล่งที่มาของ Microsoft

  1. ในฮับแบบเรียลไทม์ เลือก แหล่งข้อมูลของ Microsoft

  2. ในรายการดรอปดาวน์ แหล่งที่มา ให้เลือก Azure Cosmos DB (CDC)

  3. สําหรับ การสมัครใช้งาน ให้เลือก การสมัครใช้งาน Azure ที่มีกลุ่มทรัพยากรกับบัญชี Cosmos DB ของคุณ

  4. สําหรับ กลุ่มทรัพยากร เลือก กลุ่ม ทรัพยากรที่มีบัญชี Cosmos DB ของคุณ

  5. สําหรับ ภูมิภาค ให้เลือกตําแหน่งที่ตั้งที่ Cosmos DB ของคุณอยู่

  6. ตอนนี้ ย้ายเมาส์ไปเหนือชื่อของแหล่งข้อมูล CDC Cosmos DB ที่คุณต้องการเชื่อมต่อกับฮับเรียลไทม์ในรายการของฐานข้อมูล และเลือกปุ่มเชื่อมต่อ หรือเลือก ... (จุดไข่ปลา) จากนั้นเลือกปุ่มเชื่อมต่อ

    สกรีนช็อตที่แสดงหน้าแหล่งข้อมูลของ Microsoft พร้อมตัวกรองเพื่อแสดง Cosmos DB CDC และปุ่มเชื่อมต่อ

    หากต้องการกําหนดค่าข้อมูลการเชื่อมต่อ ให้ใช้ขั้นตอนจากเพิ่ม Azure Cosmos DB CDC เป็นส่วนต้นทาง ข้ามขั้นตอนแรกของการเลือก Azure Cosmos DB CDC เป็นชนิดแหล่งข้อมูลในตัวช่วยสร้างเพิ่มแหล่งข้อมูล

เพิ่ม Azure Cosmos DB CDC เป็นแหล่งข้อมูล

  1. บนหน้า เชื่อมต่อ เลือก การเชื่อมต่อใหม่

    สกรีนช็อตที่แสดงหน้าการเชื่อมต่อตัวช่วยสร้างการเพิ่มแหล่งข้อมูล ด้วยลิงก์ **การเชื่อมต่อใหม่** ที่มีการไฮไลต์ไว้

  2. ในส่วนการตั้งค่าการเชื่อมต่อ ระบุจุดสิ้นสุด Cosmos DB ป้อน URI หรือจุดสิ้นสุดสําหรับบัญชี Cosmos DB ของคุณที่คุณคัดลอกจากพอร์ทัล Azure

    สกรีนช็อตที่แสดงส่วนการตั้งค่าการเชื่อมต่อของหน้าการเชื่อมต่อใหม่

  3. ขยาย ตัวเลือกขั้นสูง และทําตามขั้นตอนเหล่านี้:

    1. สําหรับ จํานวนการลองใหม่ ให้ระบุจํานวนครั้งสูงสุดที่ตัวเชื่อมต่อควรส่งคําขอไปยังฐานข้อมูล Cosmos DB อีกครั้งถ้าคําขอล้มเหลวจากข้อผิดพลาดที่กู้คืนได้

    2. สําหรับ เปิดใช้งานฟังก์ชัน AVERAGE ส่งผ่านลง ระบุว่าตัวเชื่อมต่อควรส่งผ่านลงของฟังก์ชันการรวม AVG ไปยังฐานข้อมูล Cosmos DB หรือไม่

    3. สําหรับ เปิดใช้งานการจัดเรียงแบบส่งผ่านสําหรับหลายคอลัมน์ ระบุว่าตัวเชื่อมต่อควรอนุญาตให้มีหลายคอลัมน์ที่จะส่งผ่านลงไปที่ฐานข้อมูล Cosmos DB เมื่อระบุไว้ในส่วนคําสั่ง ORDER BY ของคิวรี SQL หรือไม่

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

  4. เลื่อนลง และ ในส่วน ข้อมูลประจําตัว การเชื่อมต่อ ให้ทําตามขั้นตอนเหล่านี้

    1. เลือกการเชื่อมต่อที่มีอยู่ และรักษาค่าเริ่มต้น ของตัวเลือกสร้างการเชื่อมต่อ ใหม่
    2. เมื่อต้องการสร้างการเชื่อมต่อ ให้ใส่ค่าต่อไปนี้:
      1. สําหรับ ชื่อการเชื่อมต่อ ให้ใส่ชื่อสําหรับการเชื่อมต่อ

      2. สําหรับ ชนิดการรับรองความถูกต้อง เลือก คีย์บัญชี

      3. สําหรับ คีย์บัญชี ให้ใส่ค่าคีย์ที่คุณบันทึกไว้ก่อนหน้านี้

      4. เลือก เชื่อมต่อ

        สกรีนช็อตที่แสดงส่วนข้อมูลประจําตัวการเชื่อมต่อของหน้าการเชื่อมต่อใหม่

  5. ตอนนี้ ที่ หน้าเชื่อมต่อ ทําตามขั้นตอนเหล่านี้:

    1. ระบุ ID คอนเทนเนอร์ของคอนเทนเนอร์ในบัญชี Azure Cosmos DB ของคุณ

    2. ในส่วนรายละเอียด Stream ทางด้านขวา เลือกพื้นที่ทํางาน Fabric ที่คุณต้องการบันทึกเหตุการณ์ที่เป็นตัวช่วยสร้างจะสร้าง

    3. สําหรับ ชื่อเหตุการณ์ใส่ชื่อสําหรับเหตุการณ์กระแสข้อมูล ตัวช่วยสร้างสร้างเหตุการณ์สตรีมด้วย Azure Cosmos DB CDC ที่เลือกเป็นแหล่งข้อมูล

    4. ชื่อ Stream จะถูกสร้างขึ้นสําหรับคุณโดยอัตโนมัติ โดยการผนวก -stream เข้ากับชื่อของเหตุการณ์สตรีม คุณสามารถดูสตรีมนี้บนฮับ แบบเรียลไทม์ หน้าสตรีม ข้อมูลทั้งหมดเมื่อตัวช่วยสร้างเสร็จสิ้น

    5. เลือก ถัดไป

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

  6. บนหน้าจอ ตรวจสอบ + เชื่อมต่อ ให้ตรวจสอบสรุป จากนั้นเลือก สร้างแหล่งข้อมูล

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

ดูรายละเอียดสตรีมข้อมูล

  1. บนหน้า ตรวจสอบ + เชื่อมต่อ ถ้าคุณเลือก เปิดเหตุการณ์สตรีม ตัวช่วยสร้างจะเปิดเหตุการณ์ที่สร้างขึ้นให้คุณด้วย Azure Cosmos DB CDC ที่เลือกเป็นแหล่งข้อมูล เมื่อต้องการปิดตัวช่วยสร้าง ให้เลือก ปิด หรือ X* ที่มุมบนขวาของหน้า

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

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

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

    สําหรับขั้นตอนโดยละเอียด ดูรายละเอียดของสตรีมข้อมูลใน Fabric Real-Time hub

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