หยุดสตรีมข้อมูลชั่วคราวและดําเนินต่อ

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

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

ตารางต่อไปนี้แสดงคําอธิบายเกี่ยวกับสถานะโหนดที่แตกต่างกัน:

สถานะโหนด Description
Active แหล่งข้อมูลกําลังทํางานอยู่และข้อมูลกําลังไหลเข้าหรือออกจาก Eventstream
Inactive แหล่งข้อมูลไม่ได้ใช้งานในปัจจุบัน และไม่มีข้อมูลใดไหลเข้าหรือออกจาก Eventstream
Loading แหล่งข้อมูลอยู่ในกระบวนการของการเปิดหรือปิด
Error แหล่งข้อมูลหยุดทํางานชั่วคราวในขณะนี้เนื่องจากมีข้อผิดพลาด
Warning แหล่งข้อมูลสามารถใช้งานได้ แต่พบปัญหาบางอย่าง แม้ว่าปริมาณการใช้งานข้อมูลยังคงเกิดขึ้นอยู่

การเปิดใช้งานหรือการยกเลิกโหนดโดยใช้การสลับ

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

ตารางด้านล่างอธิบายตัวเลือกประวัติย่อที่พร้อมใช้งาน:

ตัวเลือกดําเนินการต่อ Description
เมื่อหยุดการสตรีมครั้งล่าสุด ดําเนินการต่อจากจุดที่หยุดการสตรีมครั้งล่าสุด
Now ดําเนินการต่อจากเวลาปัจจุบัน
เวลาที่กําหนดเอง ดําเนินการต่อจากเวลาที่กําหนดเอง

สกรีนช็อตที่แสดงการสลับบนโหนดและรายละเอียด

Note

เมื่อกําหนดค่า Eventstream โดยทั่วไปแล้ว ต้นทาง ตรรกะการแปลงข้อมูล และปลายทางจะถูกรวมเข้าด้วยกัน ตามค่าเริ่มต้น เมื่อเผยแพร่ Eventstream บริการ Backend สําหรับทั้งการนําเข้าข้อมูลและการกําหนดเส้นทางข้อมูลเริ่มต้นด้วย Now ตามลําดับ อย่างไรก็ตาม การนําเข้าข้อมูลอาจเริ่มต้นได้เร็วกว่าการกําหนดเส้นทางข้อมูล ทําให้ข้อมูลบางอย่างถูกนําเข้าลงใน Eventstream ก่อนที่จะมีการเตรียมใช้งานเส้นทางทั้งหมด ผลที่ได้ข้อมูลนี้อาจไม่มีการกําหนดเส้นทางไปยังปลายทาง

ตัวอย่างทั่วไปคือ แหล่ง CDC ฐานข้อมูล ที่ซึ่งข้อมูลสแนปช็อตเริ่มต้นบางอย่างอาจยังคงอยู่ในอีเวนต์สตรีมโดยไม่ต้องกําหนดเส้นทางไปยังปลายทาง

เมื่อต้องการลดปัญหานี้ ให้ทําตามขั้นตอนเหล่านี้:

  1. เมื่อกําหนดค่า Eventhouse (การประมวลผลเหตุการณ์ก่อน ingestion) หรือ ปลายทางของ Lakehouse ให้ยกเลิกการเลือก เปิดใช้งานการนําเข้าหลังจากเพิ่มแหล่งข้อมูล

    สกรีนช็อตของฐานข้อมูล KQL โดยไม่ต้องเลือกเปิดใช้งานการนําเข้าหลังจากเพิ่มแหล่งข้อมูล

  2. เปิดใช้งานการนําเข้าด้วยตนเองหลังจากที่มีการเผยแพร่ Eventstream

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

    สกรีนช็อตของการกลับมาใช้ฐานข้อมูล KQL

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

Node Type รองรับหยุดชั่วคราวและดําเนินการต่อ ตัวเลือกประวัติย่อ
ฐานข้อมูล Azure Data Explorer (พรีวิว) Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
Azure Event Hubs Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
-เดี๋ยวนี้
- เวลาที่กําหนดเอง
เนมสเปซกริดเหตุการณ์ Azure Source NO
Azure Service Bus Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
ฮับ IoT Azure Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
-เดี๋ยวนี้
- เวลาที่กําหนดเอง
ข้อมูลตัวอย่าง Source YES -เดี๋ยวนี้
สภาพอากาศแบบเรียลไทม์ Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
ฐานข้อมูล Azure SQL CDC Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
ฐานข้อมูล PostgreSQL CDC Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
Oracle Database CDC (พรีวิว) Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
MongoDB CDC (พรีวิว) Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
HTTP (พรีวิว) Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
ฐานข้อมูล MySQL CDC Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
Azure Cosmos DB CDC Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
SQL Server บน VM DB CDC Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
CDC อินสแตนซ์ที่จัดการแล้วของ Azure SQL Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
ผับ/ย่อย Google Cloud Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
สตรีมข้อมูล Amazon Kinesis Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
บรรจบกัน Kafka Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
Apache Kafka Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
อเมซอน MSK Kafka Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
ปลายทางที่กําหนดเอง Source ไม่
แหล่งข้อมูลเหตุการณ์ของพื้นที่ทํางาน Fabric Source NO
เหตุการณ์ Fabric OneLake Source NO
เหตุการณ์งาน Fabric Source NO
เหตุการณ์ภาพรวมความจุแฟบริค (พรีวิว) Source NO
ที่เก็บข้อมูล Azure Blob Source NO
MQTT (พรีวิว) Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
Cribl (พรีวิว) Source NO
Solace PubSub+ (ตัวอย่าง) Source YES - เมื่อหยุดการสตรีมครั้งล่าสุด
Lakehouse Destination YES - เมื่อหยุดการสตรีมครั้งล่าสุด
-เดี๋ยวนี้
- เวลาที่กําหนดเอง
อีเวนต์เฮ้าส์ (การประมวลผลเหตุการณ์ก่อนการนําเข้า) Destination YES - เมื่อหยุดการสตรีมครั้งล่าสุด
-เดี๋ยวนี้
- เวลาที่กําหนดเอง
ปลายทางที่กําหนดเอง Destination NO
อีเวนต์เฮ้าส์ (การนําเข้าโดยตรง) Destination NO
Fabric Activator (พรีวิว) Destination YES - เมื่อหยุดการสตรีมครั้งล่าสุด
-เดี๋ยวนี้
- เวลาที่กําหนดเอง
สตรีมที่ได้รับ Destination YES - เมื่อหยุดการสตรีมครั้งล่าสุด
-เดี๋ยวนี้
- เวลาที่กําหนดเอง