Добавление источника CDC Управляемый экземпляр SQL Azure в поток событий

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

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

Примечание.

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

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

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

Примечание.

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

Включение общедоступной конечной точки в управляемом экземпляре SQL Azure

Перейдите к портал Azure, откройте управляемый экземпляр SQL Azure, выберите "Сеть" и включите общедоступную конечную точку.

Включение CDC в управляемом экземпляре SQL Azure

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

   EXEC sys.sp_cdc_enable_db; 
   

2. Включите CDC для таблицы с помощью параметра роли gating. В этом примере MyTable — имя таблицы SQL.

   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. В Службе "Аналитика в режиме реального времени" выберите eventstream , чтобы создать новый поток событий.

   

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

   

Настройка и подключение к Управляемый экземпляр SQL Azure CDC

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

   

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

   • Сервер: введите конечную точку из портал Azure, заменив запятую между узлом и портом двоеточием. Например, если ваша конечная точка имеет xxxxx.public.xxxxxx.database.windows.net,3342значение, введите xxxxx.public.xxxxxx.database.windows.net:3342 поле "Сервер ".

     

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

     

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

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

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

     Примечание.

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

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

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

5. Теперь на странице "Подключение" выберите "Все таблицы" или введите имена таблиц, разделенные запятыми, например: dbo.table1, dbo.table2

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

   

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

   

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

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

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

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

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

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