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

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

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

Примечание.

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

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

• Доступ к рабочей области в режиме лицензии емкости Fabric (или) режим пробной лицензии с разрешениями участника или более высокого уровня.
• Запущенный сервер SQL Azure с базой данных SQL Azure.
• База данных SQL Azure должна быть общедоступной, а не за брандмауэром или защищенной в виртуальной сети.
• Включен CDC в базе данных SQL Azure, выполнив хранимую процедуру 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. Теперь на странице "Подключение" введите следующие сведения:

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

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

   

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

   

Примечание.

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

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

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

   

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

   

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

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

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