แชร์ผ่าน

กําหนดเส้นทางกระแสข้อมูลตามเนื้อหาในสตรีมเหตุการณ์ Fabric

  • บทความ

บทความนี้แสดงวิธีกําหนดเส้นทางเหตุการณ์ที่ยึดตามเนื้อหาในสตรีมเหตุการณ์ Microsoft Fabric

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

การดำเนินการที่รองรับ

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

  • การรวม: สนับสนุนฟังก์ชัน SUM, AVG, MIN และ MAX ที่ทําการคํานวณในคอลัมน์ของค่า โดยแสดงผลลัพธ์เดียว

  • ขยาย: ขยายค่าอาร์เรย์และสร้างแถวใหม่สําหรับแต่ละค่าภายในอาร์เรย์

  • ตัวกรอง: เลือกหรือกรองแถวเฉพาะจากสตรีมข้อมูลตามเงื่อนไข

  • จัดกลุ่มตาม: รวมข้อมูลเหตุการณ์ทั้งหมดภายในช่วงเวลาที่กําหนด โดยมีตัวเลือกในการจัดกลุ่มคอลัมน์อย่างน้อยหนึ่งคอลัมน์

  • จัดการเขตข้อมูล: เพิ่ม ลบ หรือเปลี่ยนชนิดข้อมูลของเขตข้อมูลหรือคอลัมน์ของสตรีมข้อมูลของคุณ

  • ยูเนี่ยน: เชื่อมต่อสตรีมข้อมูลสองรายการขึ้นไปกับเขตข้อมูลที่แชร์ของชื่อและชนิดข้อมูลเดียวกันลงในสตรีมข้อมูลเดียว เขตข้อมูลที่ไม่ตรงกันจะถูกทิ้งไป

  • รวม: รวมข้อมูลจากสองสตรีมโดยยึดตามเงื่อนไขที่ตรงกันระหว่างกัน

ปลายทางที่รองรับ

ปลายทางที่รองรับคือ:

  • Lakehouse: ปลายทางนี้ช่วยให้คุณสามารถเปลี่ยนแปลงกิจกรรมแบบเรียลไทม์ของคุณก่อนการนําเข้าเข้าสู่เลคเฮาส์ของคุณ เหตุการณ์แบบเรียลไทม์จะแปลงเป็นรูปแบบ Delta Lake และจากนั้นจัดเก็บในตารางเลคเฮ้าส์ที่กําหนด ปลายทางนี้ช่วยในการสถานการณ์คลังข้อมูล

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

  • Fabric Activator: ปลายทางนี้ช่วยให้คุณเชื่อมต่อข้อมูลเหตุการณ์แบบเรียลไทม์ของคุณไปยัง Fabric Activator ได้โดยตรง Activator เป็นตัวแทนอัจฉริยะประเภทหนึ่งที่มีข้อมูลทั้งหมดที่จําเป็นในการเชื่อมต่อกับข้อมูล ตรวจสอบเงื่อนไข และดําเนินการ เมื่อข้อมูลถึงขีดจํากัดบางอย่างหรือตรงกับรูปแบบอื่น ๆ Activator จะดําเนินการที่เหมาะสมโดยอัตโนมัติ เช่น ผู้ใช้ที่แจ้งเตือนหรือเริ่มต้นเวิร์กโฟลว์ Power Automate

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

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

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

สกรีนช็อตของเหตุการณ์การกําหนดเส้นทางตามเนื้อหา

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

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