Добавить MySQL Database CDC в качестве источника в Центр реального времени

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

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

Требования

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

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

Коннектор базы данных Azure MySQL использует коннектор Debezium MySQL для фиксации изменений в вашей базе данных MySQL. Необходимо определить пользователя MySQL с разрешениями для всех баз данных, отслеживающих соединитель. Для получения пошаговых инструкций см. Настройка базы данных MySQL (DB).

Включение binlog

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

1. Перейдите в портал Azure и найдите вашу базу данных Azure MySQL.

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

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

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

   

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

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

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

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

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

2. Если вы увидите Power BI в нижней левой части страницы, переключитесь в режим работы Fabric, выбрав Power BI, а затем выбрав Fabric.

   

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

   

4. На странице центра Real-Time выберите + Источники данных в разделе Подключиться в меню слева.

   

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

   

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

   

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

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

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

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

3. Для подписки выберите подписку Azure, содержащую группу ресурсов с вашей учетной записью базы данных MySQL Azure.

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

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

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

   

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

Добавление базы данных Azure для MySQL 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".

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

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

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