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

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

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

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

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

ที่มา

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

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

• จากเมนูดรอปดาวน์ รับข้อมูล จากนั้นภายใต้ แบบต่อเนื่อง ให้เลือก Eventstream>Existing Eventstream

• เลือก รับข้อมูล จากนั้นในหน้าต่าง รับข้อมูล ให้เลือก Eventstream

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

  

กําหนดค่า

1. เลือกตารางเป้าหมาย ถ้าคุณต้องการเก็บข้อมูลลงในตารางใหม่ ให้เลือกตาราง + ตารางใหม่ และป้อนชื่อตาราง

   โน้ต

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

2. ภายใต้ กําหนดค่าแหล่งข้อมูลให้กรอกการตั้งค่าโดยใช้ข้อมูลในตารางต่อไปนี้:

   

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

3. เลือก ถัดไป

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

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

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

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

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

   สําคัญ

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

   

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

   

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

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

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

โน้ต

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

ตรวจ

แท็บ ตรวจสอบ จะเปิดขึ้นพร้อมกับแสดงตัวอย่างของข้อมูล

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

เลือก:

• เลือก Command viewer เพื่อดูและคัดลอกคําสั่งอัตโนมัติที่สร้างขึ้นจากการป้อนข้อมูลของคุณ
• เปลี่ยนรูปแบบข้อมูลที่อนุมานโดยอัตโนมัติโดยการเลือกรูปแบบที่ต้องการจากดรอปดาวน์ ข้อมูลถูกอ่านจากฮับเหตุการณ์ในรูปแบบของวัตถุ EventData รูปแบบที่ได้รับการสนับสนุนคือ CSV, JSON, PSV, SCsv, SOHsv TSV, TXT และ TSVE
• แก้ไขคอลัมน์
• สํารวจ ตัวเลือกขั้นสูงที่ยึดตามชนิดข้อมูล

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

โน้ต

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

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

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

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

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

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

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

• DateTimeFromUnixSeconds
• DateTimeFromUnixMilliseconds
• DateTimeFromUnixMicroseconds
• DateTimeFromUnixNanoseconds

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

Tabular (CSV, TSV, PSV):

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

JSON:

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

สรุป

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

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

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