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

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

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

Внимание

Расширенные возможности потоков событий Fabric в настоящее время находятся в предварительной версии.

Примечание.

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

Необходимые компоненты

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

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

Примечание.

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

Включение 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
   

3. После успешного выполнения запроса вы включили CDC в базе данных SQL Azure.

   

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

1. Выберите eventstream , чтобы создать новый поток событий. Убедитесь, что включен параметр расширенных возможностей (предварительная версия ).

   

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

   

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

1. На экране "Выбор источника данных" выберите базу данных SQL Azure (CDC).

   

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

   

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

   • Сервер. Введите имя сервера SQL Azure из портал Azure.

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

     

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

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

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

     Примечание.

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

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

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

   

6. Теперь на странице "Подключение" введите следующие сведения:

   • Выберите все таблицы или введите имена таблиц, разделенные запятыми, например dbo.table1, dbo.table2
   • Для порта значение по умолчанию равно 1433 и не может быть изменено.

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

   

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

   

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

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

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

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

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