แชร์ผ่าน

กําหนดเส้นทางสตรีมข้อมูลตามเนื้อหาใน Fabric event streams (ตัวอย่าง)

  • บทความ

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

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

สำคัญ

ความสามารถที่เพิ่มขึ้นของสตรีมเหตุการณ์ Fabric อยู่ในตัวอย่างในขณะนี้

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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