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

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

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

• SQL Server на виртуальных машинах Azure
• Amazon RDS для SQL Server
• Amazon RDS Custom for SQL Server
• Google Cloud SQL для SQL Server

Примечание.

AWS RDS SQL Server, AWS RDS Custom SQL Server и Google Cloud SQL Server не поддерживают версию Express. Убедитесь, что используется соответствующий выпуск SQL Server для CDC.

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

Примечание.

Этот источник не поддерживается в следующих регионах возможности рабочей области: Западная часть США 3, Западная Швейцария.

Предварительные условия

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

Примечание.

Максимальное количество источников и назначений для одного потока событий — 11.

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

1. Включите CDC для базы данных.

   EXEC sys.sp_cdc_enable_db; 
   

2. Включите 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 в базу данных виртуальной машины в качестве источника

1. В системе Fabric аналитики в реальном времени выберите Eventstream, чтобы создать новый поток событий.

   

2. На следующем экране выберите "Добавить внешний источник".

   

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

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

   

2. В разделе "Параметры подключения" введите следующие значения для SQL Server на виртуальной машине:

   • Сервер: введите общедоступный IP-адрес или доменное имя виртуальной машины, а затем добавьте двоеточие и порт. Например, если ваш IP-адрес — это xx.xxx.xxx.xxx, а порт равен 1433, необходимо ввести xx.xxx.xxx.xxx:1433 в поле «Сервер». Если порт не указан, используется значение 1433 порта по умолчанию.

   • База данных. Введите имя базы данных, к которой требуется подключиться на виртуальной машине SQL Server.

     

3. Прокрутите вниз и в разделе учетных данных подключения выполните следующие действия.

   • В поле "Имя подключения" введите имя подключения.

   • Для типа проверки подлинности выберите "Базовый".

     Примечание.

     В настоящее время потоки событий Fabric поддерживают только обычную проверку подлинности.

   • Введите имя пользователя и пароль для SQL Server на виртуальной машине.

     Примечание.

     Не выбирайте параметр: используйте зашифрованное подключение.

     

4. Выберите "Подключиться" в нижней части страницы.

5. Теперь на странице Connect выберите Все таблицы или Введите имена таблиц. Если выбрать последний, укажите таблицы с разделителем-запятыми полный список идентификаторов таблиц (schemaName.tableName) или допустимые регулярные выражения. Например:

   • Используйте dbo.test.*, чтобы выбрать все таблицы, имена которых начинаются с dbo.test.
   • Используйте dbo\.(test1|test2) для выбора dbo.test1 и dbo.test2.

   Вы можете смешивать оба формата с помощью запятых. Можно ввести до 100 таблиц, причем каждое имя таблицы (включая имя схемы) ограничено 128 символами, если используется полный идентификатор таблицы напрямую.

6. Выберите Далее.

   

7. На экране "Просмотр и создание" просмотрите сводку и нажмите кнопку "Подключить".

   

Просмотр обновленного потока событий

Вы можете увидеть SQL Server в источнике CDC базы данных виртуальной машины, добавленном в поток событий в режиме редактирования .

Чтобы реализовать этот недавно добавленный SQL Server на виртуальной машине в источнике CDC базы данных, выберите Опубликовать. После выполнения этих действий источник CDC базы данных SQL Server на виртуальной машине доступен для просмотра в режиме реального времени.

Связанный контент

Другие соединители:

• Потоки данных Amazon Kinesis
• Azure Cosmos DB
• Центры событий Azure
• Центр Интернета вещей Azure
• Изменение захвата данных базы данных Azure SQL (CDC)
• Confluent Kafka
• Пользовательская конечная точка
• Google Cloud Pub/Sub
• База данных PostgreSQL CDC
• Пример данных
• События в Azure Blob Storage
• Событие рабочей области Fabric