รับข้อมูลจาก Eventstream

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

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

เมื่อต้องการรับข้อมูลจากเหตุการณ์สตรีมใหม่ ให้ดู รับข้อมูลจากเหตุการณ์เหตุการณ์ใหม่

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

• พื้นที่ทํางาน ที่มีความจุ ที่เปิดใช้งาน Microsoft Fabric
• ฐานข้อมูล KQL ที่มีสิทธิ์ในการแก้ไข
• สตรีมเหตุการณ์ที่มีแหล่งข้อมูล

ขั้นตอนที่ 1: แหล่งข้อมูล

หากต้องการรับข้อมูลจากสตรีมเหตุการณ์ ให้เลือกสตรีมเหตุการณ์เป็นแหล่งข้อมูลของคุณ เลือกสตรีมเหตุการณ์ด้วยวิธีต่อไปนี้:

บนริบบิ้นของฐานข้อมูล KQL อย่างใดอย่างหนึ่ง:

• จากตัวเลือก รับข้อมูล บน Ribbon ให้เลือกไทล์ Eventstream

• จากเมนูดรอปดาวน์ รับข้อมูล เลือก เหตุการณ์สตรีม>ที่มีอยู่กระแสข้อมูล

• จากเมนูดรอปดาวน์ รับข้อมูล ให้เลือก ฮับข้อมูลReal-Time แล้วเลือกสตรีมเหตุการณ์จากรายการ

ขั้นตอนที่ 2: กําหนดค่า

1. เลือกตารางเป้าหมาย หากต้องการนําเข้าข้อมูลลงในตารางใหม่ ให้เลือก + ตารางใหม่ แล้วป้อนชื่อตาราง

   โน้ต

   ชื่อตารางสามารถมีได้สูงสุด 1,024 อักขระ รวมถึงช่องว่าง พยัญชนะผสมตัวเลข ยัติภังค์ และขีดล่าง ไม่รองรับอักขระพิเศษ

2. ภายใต้ กําหนดค่าแหล่งข้อมูล ให้ทําการตั้งค่าให้เสร็จสมบูรณ์โดยใช้ข้อมูลในตารางต่อไปนี้:

   • เมื่อคุณเลือก Eventstream เป็นแหล่งที่มาของคุณ ให้ระบุ พื้นที่ทํางานEventstream และ Stream เริ่มต้นหรือที่ได้รับมา

   สําคัญ

   คุณลักษณะในการรับข้อมูลจากสตรีมที่ได้รับอยู่ในการแสดงตัวอย่าง

   

   • เมื่อคุณเลือก ฮับReal-Time เป็นแหล่งข้อมูลของคุณ คุณเลือกสตรีมเริ่มต้นหรือมาจากรายการ และ พื้นที่ทํางานEventstream และ Stream จะถูกเติมโดยอัตโนมัติและไม่จําเป็นต้องกําหนดค่า

   

   การตั้งค่า	คําอธิบาย
   พื้นที่	ตําแหน่งที่ตั้งพื้นที่ทํางานเหตุการณ์สตรีมของคุณ เลือกพื้นที่ทํางานจากรายการดรอปดาวน์
   เหตุการณ์สตรีม	ชื่อของกระแสข้อมูลของคุณ เลือกเหตุการณ์สตรีมจากรายการดรอปดาวน์
   Stream	ชื่อของสตรีมเริ่มต้นหรือที่ได้รับมา เลือกสตรีมจากเมนูแบบเลื่อนลง * สําหรับสตรีมเริ่มต้น รูปแบบชื่อสตรีมคือ Eventstream-stream * สําหรับสตรีมที่ได้รับมา ชื่อถูกกําหนดเมื่อสร้างสตรีม
   เหตุการณ์กระบวนการก่อนการนําเข้าในกระแสข้อมูล	ตัวเลือกนี้ช่วยให้คุณสามารถกําหนดค่าการประมวลผลข้อมูลก่อนนําเข้าข้อมูลลงในตารางปลายทางได้ ถ้าเลือกแล้ว คุณจะดําเนินกระบวนการนําเข้าข้อมูลต่อใน Eventstream สําหรับข้อมูลเพิ่มเติม โปรดดู เหตุการณ์ Process ก่อน ingestion ใน Eventstream
   ชื่อการเชื่อมต่อข้อมูล	ชื่อที่ใช้เพื่ออ้างอิงและจัดการการเชื่อมต่อข้อมูลของคุณในพื้นที่ทํางานของคุณ ชื่อการเชื่อมต่อข้อมูลจะถูกเติมโดยอัตโนมัติ และคุณสามารถแก้ไขชื่อเพื่อลดความซับซ้อนของการจัดการการเชื่อมต่อข้อมูลในพื้นที่ทํางาน ชื่อสามารถมีได้เฉพาะตัวอักษรและตัวเลข ขีดกลาง และอักขระจุด และมีความยาวสูงสุด 40 อักขระ

3. เมื่อต้องการดำเนินการต่อ ให้คลิก ถัดไป

เหตุการณ์กระบวนการก่อนการนําเข้าในกระแสข้อมูล

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

เพื่อประมวลผลเหตุการณ์ก่อนการนําเข้าใน Eventstream:

1. บนแท็บ กําหนดค่า ให้เลือก เหตุการณ์ กระบวนการ ก่อนการนําเข้าในเหตุการณ์

2. ในกล่องโต้ตอบ Process ใน เหตุการณ์ ให้เลือก ดําเนินการต่อในเหตุการณ์

   สําคัญ

   การเลือก ดําเนินการต่อ ใน Eventstream จะสิ้นสุดกระบวนการรับข้อมูลใน Real-Time Intelligence และดําเนินการต่อใน Eventstream ด้วยรายละเอียดตารางปลายทางและแหล่งข้อมูลจะถูกเติมโดยอัตโนมัติ

   

3. ในเหตุการณ์ เลือกฐานข้อมูล KQL โหนดปลายทาง และในบานหน้าต่าง KQL Database ตรวจสอบว่า การประมวลผลเหตุการณ์ก่อนการนําเข้า จะถูกเลือก และรายละเอียดปลายทางถูกต้อง

   

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

5. กลับไปที่บานหน้าต่าง KQL Database เลือก เพิ่ม เพื่อดําเนินการ ฐานข้อมูล KQL การตั้งค่าโหนดปลายทาง

6. ตรวจสอบข้อมูลถูกนําเข้าลงในตารางปลายทาง

ขั้นตอนที่ 3: ตรวจสอบ

แท็บ ตรวจสอบ แสดงตัวอย่างของข้อมูล

เลือก เสร็จสิ้น เพื่อสิ้นสุดกระบวนการนําเข้า

ไม่จำเป็นต้องระบุ:

• ใช้ดรอปดาวน์ชนิดไฟล์เพื่อสํารวจตัวเลือกขั้นสูงตามชนิดข้อมูล

• ใช้รายการดรอปดาวน์ Table_mapping เพื่อกําหนดการแมปใหม่

• เลือก </> เพื่อเปิดตัวแสดงคําสั่งเพื่อดูและคัดลอกคําสั่งอัตโนมัติที่สร้างขึ้นจากอินพุตของคุณ คุณยังสามารถเปิดคําสั่งในชุดคิวรีได้อีกด้วย

• เลือกไอคอนดินสอเพื่อ แก้ไขคอลัมน์

แก้ไขคอลัมน์

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

• ชนิด ตาราง เป็นชนิดใหม่หรือที่มีอยู่
• ชนิด การแมป เป็นชนิดใหม่หรือที่มีอยู่

การแม็ปการแปลง

การแมปรูปแบบข้อมูลบางอย่าง (Parquet, JSON และ Avro) สนับสนุนการแปลงข้อมูล ingest-time แบบง่าย เมื่อต้องการใช้การแปลงการแมป ให้สร้างหรืออัปเดตคอลัมน์ในหน้าต่าง แก้ไขคอลัมน์

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

ตัวเลือกขั้นสูงที่ยึดตามชนิดข้อมูล

ตาราง (CSV, TSV และ PSV):

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

JSON:

• เลือก ระดับที่ซ้อนกัน เพื่อกําหนดการแบ่งคอลัมน์ของข้อมูล JSON ตั้งแต่ 1 ถึง 100

ขั้นตอนที่ 4: บทสรุป

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

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

• เมื่อต้องการจัดการฐานข้อมูลของคุณ ให้ดูที่ จัดการข้อมูล
• เมื่อต้องการสร้าง จัดเก็บ และส่งออกคิวรี โปรดดู คิวรีข้อมูลในชุดคิวรี KQL