Добавление my База данных SQL CDC в качестве источника в центре реального времени

В этой статье описывается, как добавить my База данных SQL Change Data Capture (CDC) в качестве источника событий в Центре реального времени Fabric.

Соединитель azure My База данных SQL Change Data Capture (CDC) позволяет записывать моментальный снимок текущих данных в базе данных Azure MySQL. Вы указываете таблицы для отслеживания и получения оповещений при последующих изменениях на уровне строк в таблицах. После записи изменений в потоке можно обрабатывать эти данные CDC в режиме реального времени и отправлять их в разные места назначения в Fabric для дальнейшей обработки или анализа.

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

• Доступ к рабочей области в режиме лицензии емкости Fabric (или) режим пробной лицензии с разрешениями участника или более высокого уровня.
• Создан экземпляр База данных Azure для MySQL — гибкий сервер.

Настройка базы данных MySQL

Соединитель базы данных Azure MySQL использует соединитель Debezium MySQL для записи изменений в my База данных SQL. Необходимо определить пользователя MySQL с разрешениями для всех баз данных, отслеживающих соединитель. Пошаговые инструкции см. в разделе "Настройка my База данных SQL(DB)".

Включение binlog

Необходимо включить двоичное ведение журнала для репликации MySQL. Двоичные журналы записывают обновления транзакций для средств репликации для распространения изменений. Например, База данных Azure для MySQL.

1. В портал Azure перейдите к базе данных Azure MySQL.

2. В меню навигации слева выберите параметры сервера.

3. Настройте сервер MySQL со следующими свойствами.

   • binlog_row_image. Задайте для значения значение full.
   • binlog_expire_logs_seconds: количество секунд для автоматического удаления файла binlog. Задайте значение, соответствующее потребностям вашей среды. Например, 86400.

   

Получение событий из Azure My База данных SQL (CDC)

События из Azure My База данных SQL CDC можно получить в центре реального времени одним из способов:

• Использование страницы источников данных
• Использование страницы источников Майкрософт

Страница «Источники данных»

1. Войдите в Microsoft Fabric.

2. Выберите режим реального времени на левой панели навигации.

3. На странице центра реального времени выберите +Источники данных в разделе "Подключиться" в меню навигации слева. Вы также можете добраться до страницы источников данных из всех потоков данных или страниц "Мои потоки данных", нажав кнопку "+ Подключить источник данных" в правом верхнем углу.

   

4. На странице источников данных выберите категорию Database CDC в верхней части и щелкните "Подключиться" на плитке Базы данных MySQL (CDC).

   

   Используйте инструкции из раздела "Добавление Azure My База данных SQL CDC в качестве исходного раздела.

Страница источников Майкрософт

1. В центре реального времени выберите источники Майкрософт.

2. В раскрывающемся списке "Источник" выберите Базу данных Azure MySQL (CDC).

3. Для подписки выберите подписку Azure с группой ресурсов с учетной записью Azure My База данных SQL.

4. Для группы ресурсов выберите группу ресурсов с базой данных.

5. В регионе выберите расположение, в котором находится ваша база данных.

6. Теперь переместите указатель мыши на имя источника CDC базы данных Azure MySQL, который требуется подключить к концентратору реального времени в списке баз данных, и нажмите кнопку "Подключить" или нажмите кнопку "Подключить". (многоточие) и нажмите кнопку "Подключить".

   

   Чтобы настроить сведения о подключении, используйте действия из раздела "Добавление CDC базы данных Базы данных Azure MySQL" в качестве исходного раздела.

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

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

   

2. В разделе параметров подключения выполните следующие действия.

   1. Для сервера введите универсальный код ресурса (URI) для сервера Azure MySQL.

   2. В поле "База данных" введите имя базы данных.

      

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

   1. Для подключения выберите, есть ли существующее подключение к базе данных MySQL. Если нет, сохраните значение по умолчанию: создайте новое подключение.

   2. Для типа проверки подлинности выберите "Базовый". В настоящее время поддерживается только обычная проверка подлинности.

   3. Введите значения имени пользователя и пароля.

   4. Укажите, следует ли использовать зашифрованное подключение.

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

      

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

   1. Введите имя таблицы.
   2. Введите идентификатор сервера.
   3. Введите номер порта или сохраните значение по умолчанию.

5. В разделе сведений о потоке справа сделайте следующее:

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

   2. Введите имя потока событий.

   3. Имя потока в концентраторе реального времени автоматически создается для вас.

      

6. Теперь нажмите кнопку "Далее " в нижней части страницы.

7. В разделе "Проверка и подключение", "Просмотр параметров" и выберите " Создать источник".

   

8. На странице "Подключение" выберите "Перейти к ресурсу", чтобы перейти к базе данных Azure PostgreSQL. Запишите имя сервера на странице обзора . Он находится в следующем формате: mysqlserver.mysql.database.azure.com

   

Просмотр сведений о потоке данных

1. На странице "Проверка и подключение" при выборе "Открыть поток событий" мастер открывает поток событий, созданный для вас с выбранным источником CDC базы данных Azure MySQL. Чтобы закрыть мастер, нажмите кнопку Готово или X* в правом верхнем углу страницы.

   

2. В центре реального времени выберите "Мои потоки данных". Чтобы просмотреть новый поток данных, обновите страницу.

   

   Подробные инструкции см. в разделе "Просмотр сведений о потоках данных" в Концентраторе реального времени Fabric.

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

Дополнительные сведения об использовании потоков данных см. в следующих статьях:

• Обработка потоков данных
• Анализ потоков данных
• Настройка оповещений в потоках данных