เพิ่มแหล่งข้อมูล CDC ของฐานข้อมูล PostgreSQL ไปยังเหตุการณ์สตรีม
บทความนี้แสดงวิธีการเพิ่มแหล่งข้อมูลการจับภาพข้อมูล (CDC) ที่เปลี่ยนแปลงฐานข้อมูล PostgreSQL ไปยังเหตุการณ์
ตัวเชื่อมต่อแหล่งที่มาของฐานข้อมูล PostgreSQL Change Data Capture (CDC) สําหรับสตรีมเหตุการณ์ของ Microsoft Fabric ช่วยให้คุณสามารถจับภาพสแนปช็อตของข้อมูลปัจจุบันในฐานข้อมูล PostgreSQL ได้ ในปัจจุบัน ฐานข้อมูล PostgreSQL Change Data Capture (CDC) ได้รับการสนับสนุนจากบริการต่อไปนี้ซึ่งสามารถเข้าถึงฐานข้อมูลแบบสาธารณะได้:
- ฐานข้อมูล Azure สําหรับ PostgreSQL
- Amazon RDS for PostgreSQL
- Amazon Aurora PostgreSQL
- Google Cloud SQL สําหรับ PostgreSQL
เมื่อแหล่งข้อมูล CDC ของฐานข้อมูล PostgreSQL ถูกเพิ่มลงในเหตุการณ์จะบันทึกการเปลี่ยนแปลงระดับแถวไปยังตารางที่ระบุ จากนั้นการเปลี่ยนแปลงเหล่านี้สามารถดําเนินการในแบบเรียลไทม์และส่งไปยังปลายทางที่แตกต่างกันสําหรับการวิเคราะห์เพิ่มเติม
หมายเหตุ
แหล่งข้อมูลนี้ไม่ได้รับการสนับสนุนในภูมิภาคต่อไปนี้ของความจุพื้นที่ทํางานของคุณ: US3 ตะวันตก สวิตเซอร์แลนด์ตะวันตก
ข้อกำหนดเบื้องต้น
เข้าถึงพื้นที่ทํางานในโหมดสิทธิ์การใช้งาน Fabric capacity (หรือ) โหมดสิทธิ์การใช้งานรุ่นทดลองใช้ที่มีสิทธิ์ผู้สนับสนุนหรือสูงกว่า
การเข้าถึงของผู้ใช้ที่ลงทะเบียนในฐานข้อมูล PostgreSQL
ฐานข้อมูล PostgreSQL ของคุณต้องสามารถเข้าถึงได้โดยสาธารณะและไม่ได้อยู่หลังไฟร์วอลล์หรือมีความปลอดภัยในเครือข่ายเสมือน
CDC ที่เปิดใช้งานในฐานข้อมูล PostgreSQL และตาราง
ถ้าคุณมีฐานข้อมูล Azure สําหรับ PostgreSQL ให้ทําตามขั้นตอนในส่วนถัดไปเพื่อเปิดใช้งาน CDC สําหรับข้อมูลโดยละเอียด โปรดดู การจําลองแบบตรรกะและการกําหนดรหัสตรรกะ - ฐานข้อมูล Azure สําหรับ PostgreSQL - เซิร์ฟเวอร์แบบยืดหยุ่น
สําหรับฐานข้อมูล PostgreSQL อื่น ๆ ดู ตัวเชื่อมต่อ Debezium สําหรับ PostgreSQL :: คู่มือ Debezium
ถ้าคุณไม่มีเหตุการณ์สตรีม ให้สร้างเหตุการณ์สตรีม
เปิดใช้งาน CDC ในฐานข้อมูล PostgreSQL ของคุณ
ส่วนนี้ใช้ ฐานข้อมูล Azure สําหรับ PostgreSQL เป็นตัวอย่าง
หากต้องการเปิดใช้งาน CDC ในฐานข้อมูล Azure ของคุณ สําหรับเซิร์ฟเวอร์แบบยืดหยุ่น PostgreSQL ให้ทําตามขั้นตอนเหล่านี้:
บนฐานข้อมูล Azure สําหรับหน้าเซิร์ฟเวอร์แบบยืดหยุ่น PostgreSQL ในพอร์ทัล Azure ให้เลือก พารามิเตอร์ ของเซิร์ฟเวอร์ในเมนูการนําทาง
บนหน้า พารามิเตอร์ของ เซิร์ฟเวอร์:
- ตั้งค่า wal_level เป็นตรรกะ
- อัปเดต max_worker_processes เป็นอย่างน้อย 16
บันทึกการเปลี่ยนแปลงและเริ่มเซิร์ฟเวอร์ใหม่
ยืนยันว่าฐานข้อมูล Azure ของคุณสําหรับอินสแตนซ์ของเซิร์ฟเวอร์แบบยืดหยุ่น PostgreSQL อนุญาตปริมาณการใช้งานเครือข่ายสาธารณะ
ให้สิทธิ์การจําลองแบบแก่ผู้ใช้ที่เป็นผู้ดูแลระบบ โดยการเรียกใช้คําสั่ง SQL ต่อไปนี้ ถ้าคุณต้องการใช้บัญชีผู้ใช้อื่นเพื่อเชื่อมต่อ PostgreSQL DB ของคุณเพื่อดึงข้อมูล CDC ตรวจสอบให้แน่ใจว่าผู้ใช้เป็นเจ้าของตาราง
ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
เปิดใช้ตัวช่วยสร้างการเลือกแหล่งข้อมูล
ถ้าคุณยังไม่ได้เพิ่มแหล่งข้อมูลใด ๆ ลงในเหตุการณ์สตรีมของคุณ ให้เลือก ใช้ไทล์แหล่งข้อมูล ภายนอก
ถ้าคุณกําลังเพิ่มแหล่งข้อมูลไปยังเหตุการณ์สตรีมที่เผยแพร่แล้ว สลับไปยัง โหมดแก้ไข เลือก เพิ่มแหล่งข้อมูล บนริบบอน แล้วเลือก แหล่งข้อมูลภายนอก
บนหน้า
กําหนดค่าและเชื่อมต่อกับฐานข้อมูล PostgreSQL CDC
บนหน้า เชื่อมต่อ เลือก การเชื่อมต่อใหม่
ในส่วน การตั้งค่าการเชื่อมต่อ ให้ป้อนข้อมูลต่อไปนี้
เซิร์ฟเวอร์: ที่อยู่เซิร์ฟเวอร์ของฐานข้อมูล PostgreSQL ของคุณ ตัวอย่างเช่น my-pgsql-server.postgres.database.azure.com
ฐานข้อมูล: ชื่อฐานข้อมูล ตัวอย่างเช่น my_database
เลื่อนลง และ ในส่วน ข้อมูลประจําตัว การเชื่อมต่อ ให้ทําตามขั้นตอนเหล่านี้
สําหรับ ชื่อการเชื่อมต่อ ให้ใส่ชื่อสําหรับการเชื่อมต่อ
สําหรับชนิดการรับรองความถูกต้อง เลือกพื้นฐาน
หมายเหตุ
ในขณะนี้ Fabric event streams สนับสนุนเฉพาะการรับรองความถูกต้องพื้นฐานเท่านั้น
ใส่ ชื่อผู้ใช้ และ รหัสผ่าน สําหรับฐานข้อมูล
เลือก เชื่อมต่อ
ตอนนี้ ที่ หน้าเชื่อมต่อ ทําตามขั้นตอนเหล่านี้:
บนหน้า ตรวจสอบ + เชื่อมต่อ ให้ตรวจสอบสรุป จากนั้นเลือก เพิ่ม
หมายเหตุ
จํานวนสูงสุดของแหล่งข้อมูลและปลายทางสําหรับหนึ่งเหตุการณ์สตรีมคือ 11
ดูเหตุการณ์ที่อัปเดตแล้ว
คุณสามารถดูแหล่ง CDC ของฐานข้อมูล PostgreSQL ที่เพิ่มไปยังเหตุการณ์สตรีม ของคุณในโหมดแก้ไข
หากต้องการใช้แหล่งข้อมูล CdC PostgreSQL DB ที่เพิ่งเพิ่มใหม่นี้ ให้เลือก เผยแพร่ หลังจากที่คุณทําตามขั้นตอนเหล่านี้แหล่งข้อมูล CDC PostgreSQL DB ของคุณจะพร้อมใช้งานสําหรับการแสดงภาพใน Live view
เนื้อหาที่เกี่ยวข้อง
ตัวเชื่อมต่ออื่นๆ:
- Amazon Kinesis Data Streams
- Azure Cosmos DB
- Azure Event Hubs
- Azure Service Bus
- Azure IoT Hub
- ฐานข้อมูล Azure SQL เปลี่ยนแปลงการเก็บข้อมูล (CDC)
- Confluent Kafka
- ปลายทางแบบกําหนดเอง
- ผับ/ย่อย Google Cloud
- ฐานข้อมูล MySQL CDC
- ฐานข้อมูล PostgreSQL CDC
- ข้อมูลตัวอย่าง
- เหตุการณ์ที่เก็บข้อมูล Azure Blob
- เหตุการณ์พื้นที่ทํางานของ Fabric