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

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

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

หมายเหตุ

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

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

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

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

สิทธิ์สําหรับการรับรองความถูกต้องของ Microsoft Entra

หากคุณต้องการใช้การรับรองความถูกต้องของ Microsoft Entra เพื่อเชื่อมต่อแอปพลิเคชันของคุณ

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

  1. ที่มุมขวาบน ให้เลือก การตั้งค่า (ไอคอนรูปเฟือง)

  2. ภายใต้ การกํากับดูแลและข้อมูลเชิงลึก ให้เลือก พอร์ทัลผู้ดูแลระบบ

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

  3. เปิดใช้งานการตั้งค่าผู้เช่าต่อไปนี้เพื่อให้สิทธิ์การเข้าถึง Fabric API ของบริการหลักสําหรับการสร้างพื้นที่ทํางาน การเชื่อมต่อ หรือไปป์ไลน์การปรับใช้:

    1. ในหน้า การตั้งค่าผู้เช่า ในส่วน การตั้งค่านักพัฒนา ให้ขยายตัวเลือก บริการหลักสามารถใช้ Fabric API ได้
    2. ตั้งค่าการสลับเป็น เปิดใช้งานแล้ว
    3. ในส่วนนําไปใช้กับ ให้เลือกทั้งองค์กร
    4. เลือก ใช้

    ภาพหน้าจอที่แสดงการตั้งค่านักพัฒนา

  4. เปิดใช้งานตัวเลือกนี้เพื่อเข้าถึง API อื่นๆ ทั้งหมด (เปิดใช้งานตามค่าเริ่มต้นสําหรับผู้เช่าใหม่):

    1. ยังอยู่บนหน้า การตั้งค่าผู้เช่า ให้ขยายตัวเลือก อนุญาตให้บริการหลักสร้างและใช้โปรไฟล์
    2. ตั้งค่าการสลับเป็น เปิดใช้งานแล้ว
    3. ในส่วนนําไปใช้กับ ให้เลือกทั้งองค์กร
    4. เลือก ใช้

เพิ่มข้อมูลปลายทางแบบกําหนดเองเป็นแหล่งข้อมูล

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

    ภาพหน้าจอที่แสดงตัวเลือกในการใช้จุดสิ้นสุดแบบกําหนดเอง

  2. ในกล่องโต้ตอบจุดสิ้นสุดแบบกําหนดเอง ใส่ชื่อสําหรับแหล่งข้อมูลแบบกําหนดเองภายใต้ชื่อแหล่งข้อมูล จากนั้นเลือกเพิ่ม

    ภาพหน้าจอที่แสดงกล่องโต้ตอบสําหรับการเพิ่มจุดสิ้นสุดแบบกําหนดเอง

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

    ภาพหน้าจอที่แสดงอีเวนต์สตรีมในโหมดแก้ไข โดยมีปุ่มเผยแพร่ถูกเน้นไว้

หมายเหตุ

สตรีมเหตุการณ์สามารถรองรับแหล่งที่มาและปลายทางที่รวมกันได้สูงสุด 11 รายการเมื่อคุณใช้ประเภทต่อไปนี้เท่านั้น:

  • แหล่งที่มา: จุดสิ้นสุดแบบกําหนดเอง
  • ปลายทาง: ปลายทางที่กําหนดเองและบ้านเหตุการณ์ที่มีการนําเข้าโดยตรง

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

เพิ่มข้อมูลปลายทางแบบกําหนดเองเป็นแหล่งข้อมูล

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

    ภาพหน้าจอที่แสดงตัวเลือกในการใช้จุดสิ้นสุดแบบกําหนดเอง

  2. บนหน้า เพิ่มแหล่งที่มา ให้เลือก เปิดใช้งานสําหรับการเชื่อมโยง Schema แล้วเลือก เพิ่ม

    ภาพหน้าจอที่แสดงแหล่งปลายทางแบบกําหนดเองพร้อมตัวเลือกในการเชื่อมโยงสคีมา

  3. ในตัวแก้ไข เมื่อต้องการเชื่อมโยงกับ Schema ใหม่หรือ Schema ที่มีอยู่จากรีจิสทรี Schema ให้เลือก Associate Schema เหตุการณ์บน Ribbon

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

  4. เมื่อต้องการใช้ Schema ที่มีอยู่ ให้เลือก เลือกจากรีจิสทรี Schema เหตุการณ์ แล้วทําตามขั้นตอนเหล่านี้:

    1. ในกล่องโต้ตอบ เชื่อมโยง Schema เหตุการณ์ ให้เลือก Schema จากรีจิสทรี Schema Schema ข้อมูลเหตุการณ์จะปรากฏบนบานหน้าต่างด้านขวา

    2. เลือก เลือก เพื่อเชื่อมโยงสคีมาเหตุการณ์กับจุดสิ้นสุดแบบกําหนดเอง

      ภาพหน้าจอที่แสดงกล่องโต้ตอบสําหรับการเชื่อมโยงสคีมาเหตุการณ์กับสคีมาที่เลือกจากรีจิสทรีสคีมา

    3. ในตัวแก้ไข eventstream ให้เลือกไทล์ eventstream ในบานหน้าต่างด้านล่าง ให้สลับไปยังแท็บ Schema ที่เกี่ยวข้อง ยืนยันว่า Schema เชื่อมโยงกับสตรีมเหตุการณ์

      ภาพหน้าจอที่แสดงตัวแก้ไข eventstream โดยเลือก eventstream และแท็บสําหรับสคีมาที่เกี่ยวข้องถูกเน้น

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

หมายเหตุ

สตรีมเหตุการณ์สามารถรองรับแหล่งที่มาและปลายทางที่รวมกันได้สูงสุด 11 รายการเมื่อคุณใช้ประเภทต่อไปนี้เท่านั้น:

  • แหล่งที่มา: จุดสิ้นสุดแบบกําหนดเอง
  • ปลายทาง: ปลายทางที่กําหนดเองและบ้านเหตุการณ์ที่มีการนําเข้าโดยตรง

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

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

หลังจากที่คุณสร้างแหล่งที่มาปลายทางแบบกําหนดเองในสตรีมเหตุการณ์แล้ว ข้อมูลของแหล่งที่มาจะพร้อมใช้งานสําหรับการแสดงภาพในมุมมองสด ใช้บานหน้าต่าง รายละเอียด เพื่อดึงสตริงการเชื่อมต่อ คีย์ SAS และโค้ดตัวอย่างที่พร้อมใช้งานสําหรับฮับเหตุการณ์, AMQP หรือโปรโตคอล Apache Kafka

ภาพหน้าจอที่แสดง eventstream ในมุมมองสด

บานหน้าต่างรายละเอียดมีแท็บโพรโทคอลสามแท็บ: Event Hub, AMQP และ Kafka แต่ละแท็บโปรโตคอลมีสองหน้าที่นําเสนอรายละเอียดปลายทางพร้อมโปรโตคอลที่เกี่ยวข้องสําหรับการเชื่อมต่อ:

  • Basic แสดงชื่อ ประเภท และสถานะของปลายทางที่กําหนดเองของคุณ

    ภาพหน้าจอที่แสดงข้อมูลพื้นฐานในบานหน้าต่างรายละเอียดของมุมมองสด eventstream

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

รายละเอียดการเชื่อมต่อโพรโทคอลฮับเหตุการณ์

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

ภาพหน้าจอที่แสดงข้อมูลสําคัญในบานหน้าต่างรายละเอียดของ eventstream

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

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

Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxx

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

ภาพหน้าจอที่แสดงปุ่มแสดงโค้ดตัวอย่างในแผงรายละเอียดของมุมมองสด eventstream

รายละเอียดการเชื่อมต่อโปรโตคอล AMQP

รูปแบบ Advanced Message Queuing Protocol (AMQP) เข้ากันได้กับ AMQP 1.0 ซึ่งเป็นโปรโตคอลการส่งข้อความมาตรฐานที่รองรับการทํางานร่วมกันระหว่างแพลตฟอร์มและภาษาต่างๆ คุณสามารถใช้รูปแบบนี้เพื่อเชื่อมต่อกับเหตุการณ์ของคุณโดยใช้โพรโทคอล AMQP ได้

ภาพหน้าจอที่แสดงคีย์ AMQP ในบานหน้าต่างรายละเอียดของมุมมองสด eventstream

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

ภาพหน้าจอที่แสดงปุ่มแสดงโค้ดตัวอย่าง AMQP ในบานหน้าต่างรายละเอียดของมุมมองสด eventstream

รายละเอียดการเชื่อมต่อโปรโตคอล Apache Kafka

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

ภาพหน้าจอที่แสดงคีย์ Kafka ในบานหน้าต่างรายละเอียดของมุมมองสด eventstream

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

ภาพหน้าจอที่แสดงปุ่มสําหรับโค้ดตัวอย่าง Kafka ในบานหน้าต่างรายละเอียดของมุมมองสด eventstream

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

หมายเหตุ

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

กําหนดค่าปลายทางสําหรับแหล่งข้อมูลที่เปิดใช้งานสคีมา

ปัจจุบัน เฉพาะ Eventhouse, ปลายทางที่กําหนดเอง และปลายทางสตรีมที่สืบทอดเท่านั้นที่รองรับ Eventstreams พร้อมสคีมาที่เกี่ยวข้อง

หมายเหตุ

ขั้นตอนในส่วนนี้ใช้กับประสบการณ์ Eventstream ที่มีอยู่แล้ว สําหรับข้อมูลเกี่ยวกับปลายทางใน Eventstreams ที่รับรู้สคีมา ดูภาพรวม Eventstreams ที่รับรู้สคีมา (ตัวอย่าง)

กําหนดค่า Schema สําหรับปลายทางปลายทางแบบกําหนดเอง

  1. เลือก แปลงเหตุการณ์ หรือ เพิ่มปลายทาง แล้วเลือก CustomEndpoint

  2. บนบานหน้าต่าง ปลายทางแบบกําหนดเอง ให้ระบุชื่อสําหรับปลายทาง

  3. สําหรับ Schema อินพุต ให้เลือก Schema สําหรับเหตุการณ์ คุณทําการเลือกในกล่องนี้เมื่อคุณเปิดใช้งานการสนับสนุน Schema สําหรับสตรีมเหตุการณ์

ภาพหน้าจอที่แสดงบานหน้าต่างสําหรับกําหนดค่าปลายทางแบบกําหนดเอง

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

กําหนดค่า Schema สําหรับปลายทางของบ้านเหตุการณ์

  1. เลือก แปลงเหตุการณ์ หรือ เพิ่มปลายทาง แล้วเลือก Eventhouse

  2. บนบานหน้าต่าง Eventhouse ให้กําหนดค่าการตั้งค่าที่เกี่ยวข้องกับ Schema ต่อไปนี้:

    1. สําหรับ Schema อินพุต ให้เลือก Schema อย่างน้อยหนึ่งรายการจากรายการดรอปดาวน์

      ภาพหน้าจอที่แสดงบานหน้าต่างการกําหนดค่า eventhouse ที่เลือกสคีมาอินพุต

      หมายเหตุ

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

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

      ภาพหน้าจอที่แสดงบานหน้าต่างการกําหนดค่า eventhouse พร้อมวิธีการสร้างตาราง

    3. สําหรับ เขียนข้อมูลด้วย ให้เลือกหนึ่งในตัวเลือกต่อไปนี้:

      • เฉพาะเพย์โหลด: เขียนข้อมูลเพย์โหลดที่ดึงออกมาลงในตาราง หากมีสคีมาอินพุตหลายรายการ ข้อมูลจะถูกส่งไปยังหลายตาราง
      • เมตาดาต้าและเพย์โหลด: เขียนเมตาดาต้าและข้อมูลเพย์โหลดลงในตารางเดียว คอลัมน์ตัวอย่าง ได้แก่ source , subject, , typeและdata

      ภาพหน้าจอที่แสดงบานหน้าต่างการกําหนดค่า eventhouse พร้อมตัวเลือกสําหรับการเขียนข้อมูล

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