Добавление источника CDC для базы данных SQL Azure в поток событий

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

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

Примечание.

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

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

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

Обратите внимание, что в базе данных SQL Azure нельзя включить зеркальное отображение.

Включить CDC в вашей базе данных SQL Azure

1. Перейдите к портал Azure, откройте базу данных SQL Azure и выберите редактор запросов. Выберите метод проверки подлинности для входа.

   

2. Выполните следующие команды SQL, чтобы включить CDC в базе данных:

   -- Enable Database for CDC
   EXEC sys.sp_cdc_enable_db;
   
   -- Enable CDC for a table using a gating role option
   EXEC sys.sp_cdc_enable_table
       @source_schema = N'dbo',
       @source_name   = N'MyTable',
       @role_name     = NULL
   GO
   

Запуск мастера выбора источника данных

Если вы еще не добавили источник в поток событий, выберите "Использовать внешнюю плитку источника ".

Если вы добавляете источник в уже опубликованный поток событий, перейдите в режим редактирования, выберите "Добавить источник" на ленте и выберите "Внешние источники".

 

На странице "Выбор источника данных" найдите и выберите "Подключиться" на плитке Базы данных SQL Azure (CDC).

Настройка и подключение к SQL Azure Базе данных CDC

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

   

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

   • Сервер: Введите имя сервера SQL Azure из портала Azure. Это в следующей форме: mysqlservername.database.windows.net

   • База данных: Введите имя базы данных SQL Azure из портала Azure.

     

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

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

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

     Примечание.

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

   • Введите имя пользователя и пароль для базы данных.

4. Нажмите Подключиться.

   

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

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

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

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

   

7. На экране "Рецензирование и создание" просмотрите сводку, а затем выберите "Добавить".

   

Примечание.

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

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

1. Источник База данных SQL Azure (CDC), добавленный в поток событий в режиме редактирования.

   

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

   

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

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

• Потоки данных Amazon Kinesis
• Azure Cosmos DB
• Центры событий Azure
• Сервисная шина Azure
• Центр Интернета вещей Azure
• Confluent Kafka
• Пользовательская конечная точка
• Google Cloud Pub/Sub
• База данных MySQL с технологией CDC
• База данных PostgreSQL CDC
• Пример данных
• События хранилища BLOB-объектов Azure
• Событие рабочей области Fabric