หมายเหตุ
การเข้าถึงหน้านี้ต้องได้รับการอนุญาต คุณสามารถลอง ลงชื่อเข้าใช้หรือเปลี่ยนไดเรกทอรีได้
การเข้าถึงหน้านี้ต้องได้รับการอนุญาต คุณสามารถลองเปลี่ยนไดเรกทอรีได้
คุณสามารถใช้คุณลักษณะสตรีมเหตุการณ์ใน Microsoft Fabric Real-Time Intelligence เพื่อนําเหตุการณ์แบบเรียลไทม์มาไว้ใน Fabric แปลง แล้วกําหนดเส้นทางไปยังปลายทางต่างๆ โดยไม่ต้องเขียนโค้ดใดๆ คุณสร้างสตรีมเหตุการณ์ เพิ่มแหล่งข้อมูลเหตุการณ์ลงในสตรีม หรือเพิ่มการแปลงเพื่อแปลงข้อมูลเหตุการณ์ แล้วกําหนดเส้นทางข้อมูลไปยังปลายทางที่รองรับ
นอกจากนี้ ด้วยตําแหน่งข้อมูล Apache Kafka ที่พร้อมใช้งานสําหรับสตรีมเหตุการณ์ คุณสามารถส่งหรือใช้เหตุการณ์แบบเรียลไทม์ได้โดยใช้โปรโตคอล Kafka
นําเหตุการณ์ลงใน Fabric
Eventstreams ให้ตัวเชื่อมต่อต้นทางเพื่อดึงข้อมูลเหตุการณ์จากแหล่งต่างๆ แหล่งข้อมูลเพิ่มเติมจะพร้อมใช้งานเมื่อคุณเปิดใช้งาน ความสามารถขั้นสูง ในขณะที่สร้างสตรีมเหตุการณ์
| Source | คำอธิบาย |
|---|---|
| Azure Data Explorer (ตัวอย่าง) | ถ้าคุณมีฐานข้อมูล Azure Data Explorer และตาราง คุณสามารถนําเข้าข้อมูลจากตารางลงใน Microsoft Fabric ได้โดยใช้กระแสเหตุการณ์ |
| Azure Event Hubs | ถ้าคุณมีฮับเหตุการณ์ Azure คุณสามารถนําเข้าข้อมูลฮับเหตุการณ์ลงใน Fabric ได้โดยใช้สตรีมเหตุการณ์ |
| Azure Event Grid (ตัวอย่าง) | ถ้าคุณมีเนมสเปซกริดเหตุการณ์ Azure คุณสามารถนําเข้าข้อมูลเหตุการณ์ MQTT หรือข้อมูลเหตุการณ์ที่ไม่ใช่ MQTT ลงใน Fabric ได้โดยใช้สตรีมเหตุการณ์ |
| Azure Service Bus (ตัวอย่าง) | คุณสามารถนําเข้าข้อมูลจากคิว Azure Service Bus หรือการสมัครใช้งานของหัวข้อลงใน Fabric โดยใช้สตรีมเหตุการณ์ |
| Azure IoT Hub | ถ้าคุณมีฮับ Azure IoT คุณสามารถนําเข้าข้อมูล IoT ลงใน Fabric ได้โดยใช้สตรีมเหตุการณ์ |
| ปลายทางที่กําหนดเอง (นั่นคือแอปที่กําหนดเองในความสามารถมาตรฐาน) | คุณลักษณะปลายทางแบบกําหนดเองช่วยให้แอปพลิเคชันหรือไคลเอ็นต์ Kafka ของคุณเชื่อมต่อกับสตรีมเหตุการณ์โดยใช้สตริงการเชื่อมต่อ การเชื่อมต่อนี้ช่วยให้การนําเข้าข้อมูลการสตรีมไปยังสตรีมเหตุการณ์เป็นไปอย่างราบรื่น |
| การดําเนินงาน Azure IoT | กําหนดค่า Azure IoT Operations เพื่อส่งข้อมูลแบบเรียลไทม์โดยตรงไปยัง Fabric Real-Time Intelligence โดยใช้จุดสิ้นสุดแบบกําหนดเองของกระแสเหตุการณ์ ความสามารถนี้สนับสนุนการรับรองความถูกต้องของ Microsoft Entra ID หรือ SASL |
| ข้อมูลตัวอย่าง | คุณสามารถเลือก จักรยาน, แท็กซี่สีเหลือง, ตลาดหุ้น, รถบัส, หุ้นของบริษัท S&P 500 หรือ บันทึกแบบจําลองความหมาย เป็นแหล่งข้อมูลตัวอย่างเพื่อทดสอบการนําเข้าข้อมูลขณะตั้งค่าสตรีมเหตุการณ์ |
| สภาพอากาศแบบเรียลไทม์ (ตัวอย่าง) | คุณสามารถเพิ่มแหล่งสภาพอากาศแบบเรียลไทม์ไปยังสตรีมเหตุการณ์เพื่อสตรีมข้อมูลสภาพอากาศแบบเรียลไทม์จากสถานที่ต่างๆ |
| ฐานข้อมูล Azure SQL เปลี่ยนแปลงการเก็บข้อมูล (CDC) | คุณสามารถใช้ตัวเชื่อมต่อแหล่งที่มาของ CDC ฐานข้อมูล Azure SQL เพื่อบันทึกสแนปช็อตของข้อมูลปัจจุบันในฐานข้อมูล Azure SQL ตัวเชื่อมต่อจะตรวจสอบและบันทึกการเปลี่ยนแปลงระดับแถวในอนาคตใดก็ตามในข้อมูลนี้ |
| ฐานข้อมูล PostgreSQL CDC | คุณสามารถใช้ตัวเชื่อมต่อแหล่งที่มาของ PostgreSQL CDC เพื่อจับภาพสแนปช็อตของข้อมูลปัจจุบันในฐานข้อมูล PostgreSQL ตัวเชื่อมต่อจะตรวจสอบและบันทึกการเปลี่ยนแปลงระดับแถวในอนาคตใดก็ตามในข้อมูลนี้ |
| HTTP (พรีวิว) | คุณสามารถใช้ตัวเชื่อมต่อ HTTP เพื่อสตรีมข้อมูลจากแพลตฟอร์มภายนอกไปยังสตรีมเหตุการณ์ได้โดยใช้คําขอ HTTP มาตรฐาน นอกจากนี้ยังมีฟีดข้อมูลสาธารณะที่กําหนดไว้ล่วงหน้าพร้อมส่วนหัวและพารามิเตอร์ที่กรอกอัตโนมัติ คุณจึงสามารถเริ่มต้นได้อย่างรวดเร็วโดยไม่ต้องตั้งค่าที่ซับซ้อน |
| MongoDB CDC (พรีวิว) | ตัวเชื่อมต่อต้นทาง MongoDB CDC สําหรับ Fabric eventstreams จะบันทึกสแนปช็อตเริ่มต้นของข้อมูลจาก MongoDB คุณสามารถระบุคอลเลกชันที่จะตรวจสอบ และสตรีมเหตุการณ์จะติดตามและบันทึกการเปลี่ยนแปลงแบบเรียลไทม์ของเอกสารในฐานข้อมูลและคอลเลกชันที่เลือก |
| ฐานข้อมูล MySQL CDC | คุณสามารถใช้ตัวเชื่อมต่อแหล่งข้อมูล MySQL Database CDC เพื่อบันทึกสแนปช็อตของข้อมูลปัจจุบันในฐานข้อมูล Azure สําหรับฐานข้อมูล MySQL คุณสามารถระบุตารางเพื่อตรวจสอบ และบันทึกเหตุการณ์สตรีมจะบันทึกการเปลี่ยนแปลงระดับแถวในอนาคตไปยังตารางได้ |
| Azure Cosmos DB CDC | คุณสามารถใช้ตัวเชื่อมต่อแหล่งข้อมูล Azure Cosmos DB CDC สําหรับสตรีมเหตุการณ์ Fabric เพื่อบันทึกสแนปช็อตของข้อมูลปัจจุบันในฐานข้อมูล Azure Cosmos DB ตัวเชื่อมต่อจะตรวจสอบและบันทึกการเปลี่ยนแปลงระดับแถวในอนาคตใดก็ตามในข้อมูลนี้ |
| SQL Server บนฐานข้อมูลเครื่องเสมือน (VM DB) CDC | คุณสามารถใช้ตัวเชื่อมต่อต้นทาง SQL Server บน VM DB CDC สําหรับสตรีมเหตุการณ์ Fabric เพื่อจับภาพสแนปช็อตของข้อมูลปัจจุบันในฐานข้อมูล SQL Server บน VM ตัวเชื่อมต่อจะตรวจสอบและบันทึกการเปลี่ยนแปลงระดับแถวในอนาคตใดก็ตามในข้อมูล |
| CDC อินสแตนซ์ที่จัดการแล้วของ Azure SQL | คุณสามารถใช้ตัวเชื่อมต่อแหล่งที่มา CDC ของอินสแตนซ์ที่มีการจัดการ Azure SQL สําหรับสตรีมเหตุการณ์ Fabric เพื่อบันทึกสแนปช็อตของข้อมูลปัจจุบันในฐานข้อมูลอินสแตนซ์ที่มีการจัดการของ SQL ตัวเชื่อมต่อจะตรวจสอบและบันทึกการเปลี่ยนแปลงระดับแถวในอนาคตใดก็ตามในข้อมูลนี้ |
| เหตุการณ์รายการพื้นที่ทํางาน Fabric | เหตุการณ์รายการพื้นที่ทํางาน Fabric เป็นเหตุการณ์ Fabric แบบไม่ต่อเนื่องที่เกิดขึ้นเมื่อมีการเปลี่ยนแปลงพื้นที่ทํางาน Fabric ของคุณ การเปลี่ยนแปลงเหล่านี้รวมถึงการสร้าง การอัปเดต หรือลบรายการ Fabric ด้วยเหตุการณ์ Fabric คุณสามารถจับภาพเหตุการณ์พื้นที่ทํางาน Fabric เหล่านี้ แปลง และกําหนดเส้นทางไปยังปลายทางต่าง ๆ ใน Fabric เพื่อการวิเคราะห์เพิ่มเติม |
| เหตุการณ์ Fabric OneLake | คุณสามารถใช้เหตุการณ์ OneLake เพื่อสมัครรับการเปลี่ยนแปลงในไฟล์และโฟลเดอร์ใน OneLake แล้วตอบสนองต่อการเปลี่ยนแปลงเหล่านั้นแบบเรียลไทม์ ด้วยสตรีมเหตุการณ์ Fabric คุณสามารถบันทึกเหตุการณ์ OneLake เหล่านี้ แปลง และกําหนดเส้นทางไปยังปลายทางต่างๆ ใน Fabric เพื่อการวิเคราะห์เพิ่มเติม การผสานรวมเหตุการณ์ OneLake ภายในสตรีมเหตุการณ์ Fabric อย่างราบรื่นนี้ช่วยให้คุณมีความยืดหยุ่นมากขึ้นในการตรวจสอบและวิเคราะห์กิจกรรมใน OneLake |
| งานผ้า | คุณสามารถใช้เหตุการณ์งานเพื่อสมัครรับการเปลี่ยนแปลงที่เกิดขึ้นเมื่อ Fabric เรียกใช้งาน ตัวอย่างเช่น คุณสามารถตอบสนองต่อการเปลี่ยนแปลงเมื่อรีเฟรชแบบจําลองความหมายเรียกใช้ไปป์ไลน์ตามกําหนดเวลาหรือเรียกใช้สมุดบันทึกได้ แต่ละกิจกรรมเหล่านี้สามารถสร้างงานที่สอดคล้องกันซึ่งจะสร้างชุดของเหตุการณ์งานที่สอดคล้องกันตามลําดับ ด้วยสตรีมเหตุการณ์ของ Fabric คุณสามารถบันทึกเหตุการณ์งานเหล่านี้ แปลง และกําหนดเส้นทางไปยังปลายทางต่างๆ ใน Fabric เพื่อการวิเคราะห์เพิ่มเติม การผสานรวมเหตุการณ์งานภายในสตรีมเหตุการณ์ Fabric อย่างราบรื่นนี้ช่วยให้คุณมีความยืดหยุ่นมากขึ้นในการตรวจสอบและวิเคราะห์กิจกรรมในงานของคุณ |
| เหตุการณ์ภาพรวมความจุแฟบริค (พรีวิว) | เหตุการณ์ภาพรวมความจุแฟบริคให้ข้อมูลระดับสรุปเกี่ยวกับความจุของคุณ คุณสามารถใช้เหตุการณ์เหล่านี้เพื่อสร้างการแจ้งเตือนที่เกี่ยวข้องกับความสมบูรณ์ของความจุของคุณผ่าน Fabric Activator คุณยังสามารถจัดเก็บเหตุการณ์เหล่านี้ไว้ใน Eventhouse สําหรับการวิเคราะห์แบบละเอียดหรือในอดีต |
| เหตุการณ์ที่เก็บข้อมูล Azure Blob | เหตุการณ์ Azure Blob Storage จะถูกทริกเกอร์เมื่อไคลเอ็นต์สร้าง แทนที่ หรือลบ blob คุณสามารถใช้ตัวเชื่อมต่อเพื่อเชื่อมโยงเหตุการณ์ Blob Storage กับเหตุการณ์ Fabric ในฮับแบบเรียลไทม์ คุณสามารถแปลงเหตุการณ์เหล่านี้เป็นสตรีมข้อมูลแบบต่อเนื่องและแปลงได้ก่อนที่จะกําหนดเส้นทางไปยังปลายทางต่างๆ ใน Fabric |
| ผับ/ย่อย Google Cloud | Google Pub/Sub เป็นบริการส่งข้อความที่ช่วยให้คุณสามารถเผยแพร่และสมัครสมาชิกสตรีมของเหตุการณ์ได้ คุณสามารถเพิ่ม Google Pub/Sub เป็นแหล่งข้อมูลให้กับเหตุการณ์ของคุณเพื่อจับภาพ แปลง และกําหนดเส้นทางเหตุการณ์แบบเรียลไทม์ไปยังปลายทางต่าง ๆ ใน Fabric ได้ |
| สตรีมข้อมูล Amazon Kinesis | Amazon Kinesis Data Streams เป็นบริการนําเข้าและประมวลผลข้อมูลที่ปรับขนาดได้มหาศาลและมีความทนทานสูง ซึ่งได้รับการปรับให้เหมาะสมสําหรับการสตรีมข้อมูล โดยการรวม Amazon Kinesis Data Streams เป็นแหล่งข้อมูลภายในเหตุการณ์ของคุณ คุณสามารถประมวลผลสตรีมข้อมูลแบบเรียลไทม์ได้อย่างราบรื่นก่อนที่จะกําหนดเส้นทางไปยังหลายปลายทางภายใน Fabric |
| ระบบคลาวด์ของ Confluent สําหรับ Apache Kafka | Confluent Cloud สําหรับ Apache Kafka เป็นแพลตฟอร์มสตรีมมิ่งที่นําเสนอฟังก์ชันการสตรีมและการประมวลผลข้อมูลที่มีประสิทธิภาพโดยใช้ Apache Kafka โดยการรวม Confluent Cloud สําหรับ Apache Kafka เป็นแหล่งข้อมูลภายในเหตุการณ์ของคุณ คุณสามารถประมวลผลสตรีมข้อมูลแบบเรียลไทม์ได้อย่างราบรื่นก่อนที่จะกําหนดเส้นทางไปยังหลายปลายทางภายใน Fabric |
| Apache Kafka (ตัวอย่าง) | Apache Kafka เป็นโอเพนซอร์สแพลตฟอร์มแบบกระจายสําหรับการสร้างระบบข้อมูลแบบเรียลไทม์ที่ปรับขนาดได้ ด้วยการผสานรวม Apache Kafka เป็นแหล่งที่มาภายในสตรีมเหตุการณ์ของคุณ คุณจะสามารถนําเหตุการณ์แบบเรียลไทม์จาก Apache Kafka และประมวลผลได้อย่างราบรื่นก่อนที่จะกําหนดเส้นทางไปยังปลายทางหลายแห่งภายใน Fabric |
| อเมซอน MSK Kafka | Amazon MSK Kafka เป็นบริการ Kafka ที่มีการจัดการเต็มรูปแบบ ซึ่งช่วยลดความยุ่งยากในการตั้งค่า การปรับขนาด และการจัดการ ด้วยการผสานรวม Amazon MSK Kafka เป็นแหล่งที่มาภายในสตรีมเหตุการณ์ของคุณ คุณจะสามารถนําเหตุการณ์แบบเรียลไทม์จาก MSK Kafka และประมวลผลได้อย่างราบรื่นก่อนที่จะกําหนดเส้นทางไปยังปลายทางหลายแห่งภายใน Fabric |
| MQTT (ตัวอย่าง) | คุณสามารถใช้สตรีมเหตุการณ์ Fabric เพื่อเชื่อมต่อกับโบรกเกอร์ MQTT ข้อความในโบรกเกอร์ MQTT สามารถนําเข้าไปยังสตรีมเหตุการณ์ของ Fabric และกําหนดเส้นทางไปยังปลายทางต่างๆ ภายใน Fabric |
| Cribl (พรีวิว) | คุณสามารถเชื่อมต่อ Cribl กับสตรีมเหตุการณ์และกําหนดเส้นทางข้อมูลไปยังปลายทางต่างๆ ภายใน Fabric |
| Solace PubSub+ (ตัวอย่าง) | คุณสามารถใช้สตรีมเหตุการณ์ Fabric เพื่อเชื่อมต่อกับ Solace PubSub+ ข้อความจาก Solace PubSub+ สามารถนําเข้าไปยังสตรีมเหตุการณ์ของ Fabric และกําหนดเส้นทางไปยังปลายทางต่างๆ ภายใน Fabric |
ประมวลผลเหตุการณ์โดยใช้ประสบการณ์แบบไม่ใช้โค้ด
ไดอะแกรมโฟลว์ข้อมูลแบบ end-to-end ในสตรีมเหตุการณ์สามารถให้ความเข้าใจที่ครอบคลุมเกี่ยวกับโฟลว์ข้อมูลและองค์กร
ตัวแก้ไขตัวประมวลผลเหตุการณ์เป็นประสบการณ์การลากและวาง เป็นวิธีที่ใช้งานง่ายในการสร้างตรรกะการประมวลผลข้อมูลเหตุการณ์ การแปลง และการกําหนดเส้นทางโดยไม่ต้องเขียนโค้ดใดๆ
| การแปลงข้อมูล | คำอธิบาย |
|---|---|
| ตัวกรอง | ใช้การแปลงนี้เพื่อกรองเหตุการณ์ตามค่าของฟิลด์ในการป้อนข้อมูล การแปลงจะเก็บค่าที่ตรงกับเงื่อนไขที่เลือก เช่น is null หรือ is not nullโดยขึ้นอยู่กับชนิดข้อมูล (ตัวเลขหรือข้อความ) |
| จัดการฟิลด์ | ใช้การแปลงนี้เพื่อเพิ่ม ลบ เปลี่ยนแปลง (ชนิดข้อมูล) หรือเปลี่ยนชื่อเขตข้อมูลที่มาจากอินพุตหรือการแปลงอื่น |
| รวม | ใช้การแปลงนี้เพื่อคํานวณการรวม (ผลรวม ต่ําสุด สูงสุด หรือค่าเฉลี่ย) ทุกครั้งที่เกิดเหตุการณ์ใหม่ในช่วงเวลาหนึ่ง การดําเนินการนี้ยังช่วยให้สามารถเปลี่ยนชื่อคอลัมน์จากการคํานวณเหล่านี้ พร้อมกับการกรองหรือแบ่งส่วนการรวมตามมิติข้อมูลอื่นๆ ในข้อมูลของคุณ คุณสามารถมีการรวมอย่างน้อยหนึ่งรายการในการแปลงเดียวกัน |
| จัดกลุ่มตาม | ใช้การแปลงนี้เพื่อคํานวณการรวมของเหตุการณ์ทั้งหมดภายในกรอบเวลาที่กําหนด คุณสามารถจัดกลุ่มตามค่าในเขตข้อมูลอย่างน้อยหนึ่งหรือมากกว่า มันเหมือนกับการแปลง Aggregate ที่อนุญาตให้เปลี่ยนชื่อคอลัมน์ได้ แต่มีตัวเลือกเพิ่มเติมสําหรับการรวมและมีตัวเลือกที่ซับซ้อนมากขึ้นสําหรับกรอบเวลา เช่นเดียวกับ การรวม คุณสามารถเพิ่มการรวมได้มากกว่าหนึ่งรายการต่อการแปลง |
| สหภาพ | ใช้การแปลงนี้เพื่อเชื่อมต่อโหนดตั้งแต่สองโหนดขึ้นไป และเพิ่มเหตุการณ์ที่มีฟิลด์ที่ใช้ร่วมกัน (ที่มีชื่อและประเภทข้อมูลเดียวกัน) ลงในตารางเดียว เขตข้อมูลที่ไม่ตรงกันจะถูกทิ้งและไม่รวมอยู่ในเอาต์พุต |
| ขยาย | ใช้การแปลงนี้เพื่อสร้างแถวใหม่สําหรับแต่ละค่าภายในอาร์เรย์ |
| ต่อ | ใช้การแปลงนี้เพื่อรวมข้อมูลจากสองสตรีมตามเงื่อนไขการจับคู่ระหว่างสตรีม |
หากคุณเปิดใช้งานความสามารถ ขั้นสูง ขณะสร้างสตรีมเหตุการณ์ การดําเนินการแปลงจะได้รับการสนับสนุนสําหรับปลายทางทั้งหมด สตรีมที่ได้รับจะทําหน้าที่เป็นสะพานเชื่อมกลางสําหรับปลายทางบางแห่ง เช่น ปลายทางที่กําหนดเองหรือ Fabric Activator) หากคุณไม่ได้เปิดใช้งาน ความสามารถขั้นสูง การดําเนินการแปลงจะพร้อมใช้งานสําหรับปลายทางเลคเฮาส์และอาคารเหตุการณ์ (การประมวลผลเหตุการณ์ก่อนการนําเข้า) เท่านั้น
กําหนดเส้นทางเหตุการณ์ไปยังปลายทาง
คุณลักษณะ Fabric eventstreams รองรับการส่งข้อมูลไปยังปลายทางที่รองรับต่อไปนี้
| ปลายทาง | คำอธิบาย |
|---|---|
| ปลายทางที่กําหนดเอง (แอปแบบกําหนดเองในความสามารถมาตรฐาน) | ใช้ปลายทางนี้เพื่อกําหนดเส้นทางเหตุการณ์แบบเรียลไทม์ของคุณไปยังปลายทางที่กําหนดเอง คุณสามารถเชื่อมต่อแอปพลิเคชันของคุณเองกับเหตุการณ์สตรีม และใช้ข้อมูลเหตุการณ์ในแบบเรียลไทม์ได้ ปลายทางนี้มีประโยชน์เมื่อคุณต้องการส่งข้อมูลแบบเรียลไทม์ไปยังระบบภายนอก Microsoft Fabric |
| อีเวนต์เฮ้าส์ | ปลายทางนี้ช่วยให้คุณสามารถนําเข้าข้อมูลเหตุการณ์แบบเรียลไทม์ของคุณไปยัง Eventhouse ซึ่งคุณสามารถใช้ Kusto Query Language (KQL) อันทรงพลังเพื่อสืบค้นและวิเคราะห์ข้อมูลได้ ด้วยข้อมูลในบ้านเหตุการณ์ คุณจะได้รับข้อมูลเชิงลึกที่ลึกซึ้งยิ่งขึ้นเกี่ยวกับข้อมูลเหตุการณ์ของคุณ และสร้างรายงานและแดชบอร์ดที่สมบูรณ์ คุณสามารถเลือกระหว่างโหมดการนําเข้าสองโหมด: การนําเข้าโดยตรง และ การประมวลผลเหตุการณ์ก่อนการนําเข้าข้อมูลได้ |
| เลคเฮ้าส์ | ปลายทางนี้ช่วยให้คุณสามารถแปลงเหตุการณ์แบบเรียลไทม์ของคุณก่อนที่จะนําเข้าลงในเลคเฮ้าส์ของคุณ เหตุการณ์แบบเรียลไทม์จะถูกแปลงเป็นรูปแบบ Delta Lake แล้วจัดเก็บไว้ในตารางเลคเฮาส์ที่กําหนด ปลายทางนี้สนับสนุนสถานการณ์คลังข้อมูล |
| สตรีมที่ได้รับมา | คุณสามารถสร้างปลายทางชนิดพิเศษนี้ได้หลังจากที่คุณเพิ่มการดําเนินการสตรีม เช่น ตัวกรอง หรือ จัดการฟิลด์ ลงในสตรีมเหตุการณ์ สตรีมที่ได้รับแสดงถึงสตรีมเริ่มต้นที่แปลงแล้วหลังจากการประมวลผลสตรีม คุณสามารถกําหนดเส้นทางสตรีมที่ได้รับไปยังปลายทางหลายแห่งใน Fabric และดูสตรีมที่ได้รับในฮับแบบเรียลไทม์ |
| Fabric Activator (ตัวอย่าง) | คุณสามารถใช้ปลายทางนี้เพื่อเชื่อมต่อข้อมูลเหตุการณ์แบบเรียลไทม์ของคุณกับ Fabric Activator ได้โดยตรง Activator เป็นตัวแทนอัจฉริยะประเภทหนึ่งที่มีข้อมูลทั้งหมดที่จําเป็นในการเชื่อมต่อกับข้อมูล เมื่อข้อมูลถึงเกณฑ์ที่กําหนดหรือตรงกับรูปแบบอื่นๆ Activator จะดําเนินการที่เหมาะสมโดยอัตโนมัติ เช่น การแจ้งเตือนผู้ใช้หรือการเริ่มต้นเวิร์กโฟลว์ Power Automate |
คุณสามารถแนบปลายทางหลายรายการในสตรีมเหตุการณ์เพื่อรับข้อมูลจากสตรีมเหตุการณ์ของคุณพร้อมกันโดยที่สตรีมเหตุการณ์ไม่รบกวนซึ่งกันและกัน
หมายเหตุ
เราขอแนะนําให้คุณใช้คุณลักษณะ Fabric eventstreams ที่มีหน่วยความจุอย่างน้อยสี่หน่วย (SKU: F4)
Apache Kafka บน Fabric eventstreams
คุณลักษณะ Fabric eventstreams มีตําแหน่งข้อมูล Apache Kafka ดังนั้นคุณจึงสามารถเชื่อมต่อและใช้เหตุการณ์การสตรีมผ่านโปรโตคอล Kafka หากแอปพลิเคชันของคุณใช้โปรโตคอล Apache Kafka เพื่อส่งหรือรับเหตุการณ์การสตรีมที่มีหัวข้อเฉพาะอยู่แล้ว คุณก็สามารถเชื่อมต่อกับสตรีมเหตุการณ์ของคุณได้อย่างง่ายดาย เพียงอัปเดตการตั้งค่าการเชื่อมต่อของคุณเพื่อใช้ตําแหน่งข้อมูล Kafka ที่มีให้ในสตรีมเหตุการณ์ของคุณ
คุณลักษณะ Fabric eventstreams เชื่อมโยงกับ Azure Event Hubs ซึ่งเป็นบริการระบบคลาวด์ที่มีการจัดการเต็มรูปแบบ เมื่อคุณสร้างสตรีมเหตุการณ์ namespace ฮับเหตุการณ์จะถูกเตรียมใช้งานโดยอัตโนมัติ ฮับเหตุการณ์ถูกจัดสรรให้กับสตรีมเริ่มต้นโดยไม่ต้องมีการกําหนดค่าการเตรียมใช้งานใดๆ เมื่อต้องการเรียนรู้เพิ่มเติมเกี่ยวกับคุณลักษณะที่เข้ากันได้กับ Kafka ใน Azure Event Hubs โปรดดู Azure Event Hubs สําหรับ Apache Kafka คืออะไร
หากต้องการเรียนรู้เพิ่มเติมเกี่ยวกับวิธีรับรายละเอียดตําแหน่งข้อมูล Kafka สําหรับการส่งเหตุการณ์ไปยังสตรีมเหตุการณ์ โปรดดู เพิ่มตําแหน่งข้อมูลแบบกําหนดเองหรือแหล่งที่มาของแอปแบบกําหนดเองไปยังสตรีมเหตุการณ์ สําหรับข้อมูลเกี่ยวกับการใช้เหตุการณ์จากสตรีมเหตุการณ์ โปรดดู เพิ่มปลายทางที่กําหนดเองหรือปลายทางของแอปแบบกําหนดเองไปยังสตรีมเหตุการณ์
ขีด จำกัด
สตรีมเหตุการณ์ของแฟบริคมีข้อจํากัดทั่วไปดังต่อไปนี้ ก่อนที่คุณจะทํางานกับสตรีมเหตุการณ์ ให้ตรวจสอบข้อจํากัดเหล่านี้เพื่อให้แน่ใจว่าสอดคล้องกับความต้องการของคุณ
| ขีดจำกัด | ค่า |
|---|---|
| ขนาดข้อความสูงสุด | 1 เมกะไบต์ |
| ระยะเวลาการเก็บข้อมูลสูงสุดของข้อมูลเหตุการณ์ | 90 วัน |
| การรับประกันการจัดส่งเหตุการณ์ | อย่างน้อยหนึ่งครั้ง |