Добавьте Базу данных PostgreSQL CDC как источник в узел Real-Time

2025-07-21

В этой статье описывается, как добавить отслеживание изменений данных (CDC) базы данных PostgreSQL в качестве источника событий в узле Real-Time Fabric.

Коннектор источника отслеживания изменений данных (CDC) для потоков событий Microsoft Fabric в базе данных PostgreSQL позволяет записывать моментальный снимок текущих данных. Затем соединитель отслеживает и записывает любые будущие изменения на уровне строк в эти данные.

Prerequisites

Доступ к рабочей области в режиме лицензии на емкость Fabric или в режиме пробной лицензии с разрешениями Контрибьютора или более высокого уровня.
Зарегистрированный доступ пользователей в базе данных PostgreSQL.
CDC включен в базе данных PostgreSQL.

Если у вас есть База данных Azure для PostgreSQL, выполните действия, описанные в следующем разделе, чтобы включить CDC. Подробные сведения см. в разделе "Логическая репликация и логическое декодирование" — База данных Azure для PostgreSQL — гибкий сервер.

Для других баз данных PostgreSQL см. Debezium connector for PostgreSQL :: документация Debezium.

Note

Несколько таблиц CDC не поддерживаются.

Включение CDC в базе данных Azure для PostgreSQL

Чтобы включить CDC в базе данных Azure для PostgreSQL, выполните следующие действия в зависимости от типа развертывания.

Отдельный сервер База данных Azure для PostgreSQL

Перейдите на страницу репликации на портале Azure.
Измените правило репликации на логический.

Гибкий сервер Базы данных Azure для PostgreSQL

На странице гибкого сервера Базы данных Azure для PostgreSQL на портале Azure выберите параметры сервера в меню навигации.
На странице параметров сервера:
- Установите wal_level на логический.
- Обновите max_worker_processes до значения не менее 16.
Сохраните изменения и перезапустите сервер.
Убедитесь, что гибкий экземпляр сервера Базы данных Azure для PostgreSQL разрешает общедоступный сетевой трафик.
Предоставьте администраторам разрешения на репликацию, выполнив следующую инструкцию SQL.
```
ALTER ROLE <admin user> WITH REPLICATION;
```

Получение событий из базы данных Azure для PostgreSQL CDC

События из базы данных Azure для PostgreSQL CDC можно получить в центре Real-Time одним из следующих способов:

Использование страницы источников данных
Использование страницы источников Майкрософт

Страница источников данных

Войдите в Microsoft Fabric.
Если вы видите Power BI в нижней левой части страницы, переключитесь на рабочую нагрузку Fabric, выбрав Power BI, а затем выбрав Fabric.
Выберите режим реального времени на левой панели навигации.
На странице Real-Time Hub выберите + Источники данных в разделе Подключение к в меню навигации слева.

Вы также можете добраться до страницы источников данных на странице Real-Time концентратора , нажав кнопку +Добавить данные в правом верхнем углу.

На странице источников данных выберите категорию источников Майкрософт в верхней части и щелкните "Подключиться" на плитке Azure DB для PostgreSQL (CDC).

Используйте инструкции из раздела «Добавление базы данных PostgreSQL CDC как источника».

Страница источников Майкрософт

В центре реального времени выберите источники Майкрософт.
В раскрывающемся списке "Источник" выберите PostgreSQL (CDC).
В разделе Подписка выберите такую подписку Azure, которая содержит группу ресурсов с вашей учетной записью базы данных PostgreSQL.
Для группы ресурсов выберите группу ресурсов с базой данных.
В регионе выберите расположение, в котором находится ваша база данных.
Теперь переместите указатель мыши на имя источника CDC базы данных PostgreSQL, который требуется подключить к центру Real-Time в списке баз данных. Затем нажмите кнопку "Подключить", или выберите ... (многоточие), а затем нажмите кнопку "Подключить".

Чтобы настроить сведения о подключении, выполните действия из раздела "Добавление Azure Database для PostgreSQL CDC в качестве источника".

Добавьте Azure Database for PostgreSQL CDC в качестве источника

На странице "Подключение" выберите "Создать подключение".

Если у вас есть подключение к источнику CDC базы данных Azure для PostgreSQL, его можно выбрать из раскрывающегося списка "Подключение" и перейти к настройке порта и таблиц.
В разделе "Параметры подключения" введите следующие сведения.
- Сервер: адрес сервера базы данных PostgreSQL, например my-pgsql-server.postgres.database.azure.com.
- База данных: имя базы данных, например my_database.
Прокрутите вниз и в разделе учетных данных подключения выполните следующие действия.
1. В поле "Имя подключения" введите имя подключения.
2. Для типа проверки подлинности выберите "Базовый".
  
  Note
  
  В настоящее время потоки событий Fabric поддерживают только обычную проверку подлинности.
3. Введите имя пользователя и пароль для базы данных.
4. Нажмите Подключиться.
Теперь на странице "Подключение" выполните следующие действия:
1. Для таблицы введите имя таблицы.
2. Для порта введите номер порта или оставьте значение по умолчанию: 5432.
3. Для имени потока событий введите имя потока событий. Мастер создает поток событий с выбранной базой данных PostgreSQL CDC в качестве источника.
4. Имя потока автоматически создается путем добавления -stream к имени потока событий. Этот поток отображается на странице "Все потоки данных" после завершения работы мастера.
5. Выберите Далее в нижней части страницы.
На странице "Рецензирование и подключение" просмотрите сводку и нажмите кнопку "Подключить".

Просмотр сведений о потоке данных

На странице "Проверка и подключение " при выборе "Открыть поток событий" мастер открывает поток событий, созданный для вас с выбранной базой данных PostgreSQL CDC в качестве источника. Чтобы закрыть мастер, нажмите кнопку Готово в нижней части страницы.
Поток должен отображаться в разделе "Последние потоковые данные" на главной странице центраReal-Time. Подробные инструкции см. в разделе «Просмотр сведений о потоках данных в Fabric Real-Time Hub».

Дополнительные сведения об использовании потоков данных см. в следующих статьях: