Добавление SQL Server в базу данных виртуальной машины (CDC) в качестве источника в концентраторе реального времени

2025-06-05

В этой статье описывается, как добавить SQL Server в базу данных виртуальных машин (CDC) в качестве источника событий в концентраторе Реального времени Fabric.

Соединитель источника для потоков событий Fabric, предназначенный для базы данных SQL Server на виртуальной машине (CDC), позволяет захватывать моментальный снимок текущих данных в этой базе данных. Затем соединитель отслеживает и записывает любые будущие изменения на уровне строк в данные. После записи этих изменений в потоке событий можно обрабатывать эти данные в режиме реального времени и отправлять их в различные места для дальнейшей обработки или анализа.

Требования

Доступ к рабочей области в режиме лицензии на емкость Fabric или в режиме пробной лицензии с разрешениями Контрибьютора или более высокого уровня.
Работающий SQL Server на базе данных виртуальной машины.
Для предоставления общедоступного доступа необходимо настроить SQL Server в базе данных виртуальной машины.
Включите CDC в базе данных SQL Server на виртуальной машине, выполнив хранимую процедуру sys.sp_cdc_enable_db. Дополнительные сведения см. в разделе "Включение и отключение записи измененных данных".

Включение CDC в SQL Server в базе данных виртуальной машины

Включите CDC для базы данных.
```
EXEC sys.sp_cdc_enable_db; 
```
Включите CDC для таблицы, используя параметр роли контроля доступа. В этом примере MyTable — имя таблицы SQL.
```
EXEC sys.sp_cdc_enable_table 
   @source_schema = N'dbo', 
   @source_name   = N'MyTable', 
   @role_name     = NULL 
GO 
```
После успешного выполнения запроса вы включили CDC в базе данных SQL Server на виртуальной машине.

Получение событий из SQL Server в базе данных виртуальной машины (CDC)

События из SQL Server в виртуальной машине (CDC) можно получать в Real-Time Hub с помощью страницы источников данных.

Страница «Источники данных»

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

Вы также можете добраться до страницы источников данных из всех потоков данных или страниц "Мои потоки данных", нажав кнопку "+ Подключить источник данных" в правом верхнем углу.

На странице источников данных выберите категорию Database CDC в верхней части и щелкните "Подключиться" на плитке БАЗЫ данных SQL Azure MI DB (CDC).

Используйте инструкции из раздела «Добавление SQL Server на ВМ DB CDC в качестве источника».

Добавление SQL Server в CDC базы данных виртуальной машины в качестве источника

На странице "Подключение" выберите "Создать подключение".
В разделе "Параметры подключения" введите следующие значения для SQL Server на виртуальной машине:
- Сервер: введите общедоступный IP-адрес или доменное имя виртуальной машины, а затем добавьте двоеточие и порт. Например, если ваш IP-адрес и порт — 1433, необходимо ввести в поле «Сервер» . Если порт не указан, используется значение 1433 порта по умолчанию.
- База данных. Введите имя базы данных, к которой требуется подключиться на виртуальной машине SQL Server.
Прокрутите вниз и в разделе учетных данных подключения выполните следующие действия.
- В поле "Имя подключения" введите имя подключения.
- Для типа проверки подлинности выберите "Базовый".
  
  Примечание.
  
  В настоящее время потоки событий Fabric поддерживают только обычную проверку подлинности.
- Введите имя пользователя и пароль для SQL Server на виртуальной машине.
  
  Примечание.
  
  Не выбирайте параметр: используйте зашифрованное подключение.
Выберите "Подключиться" в нижней части страницы.
Теперь на странице Connect выберите Все таблицы или Введите имя(имена) таблиц. Если выберете последний вариант, укажите таблицы, используя список полных идентификаторов таблиц, разделённых запятыми (schemaName.tableName), или допустимые регулярные выражения. Рассмотрим пример.
- Используйте dbo.test.*, чтобы выбрать все таблицы, имена которых начинаются с dbo.test.
- Используйте dbo\.(test1|test2) для выбора dbo.test1 и dbo.test2.
Вы можете смешивать оба формата с помощью запятых. Можно ввести до 100 таблиц, причем каждое имя таблицы (включая имя схемы) ограничено 128 символами, если используется полный идентификатор таблицы напрямую.
Вы можете развернуть дополнительные параметры, чтобы настроить режим обработки десятичных знаков, который указывает, как соединитель обрабатывает значения столбцов DECIMAL и NUMERIC.
- Precise: представляет значения, использующие точные десятичные типы (например, Java BigDecimal), чтобы обеспечить полную точность и точность представления данных.
- Double: преобразует значения в числа с плавающей запятой двойной точности. Это повышает удобство использования и производительность, но может привести к потере точности.
- String: кодирует значения в виде форматированных строк. Это упрощает использование в последующих системах, но приводит к потере семантической информации о исходном числовом типе.
Выберите Далее.
На экране "Просмотр и создание" просмотрите сводку и нажмите «Подключить».

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

На странице "Проверка и подключение" при выборе "Открыть поток событий" мастер открывает поток событий, созданный для вас с выбранным SQL Server в базе данных виртуальной машины (CDC) в качестве источника. Чтобы закрыть мастер, нажмите кнопку Закрыть или X* в правом верхнем углу страницы.
В концентраторе реального времени выберите все потоки данных. Чтобы просмотреть новый поток данных, обновите страницу "Все потоки данных". Для подробных инструкций см. в разделе «Просмотр сведений о потоках данных в Fabric Real-Time Hub».

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

Поделиться через