Поделиться через

Добавление источника CDC Azure Cosmos DB в поток событий

  • Статья

В этой статье показано, как добавить источник записи данных в поток событий Azure Cosmos DB (Azure Cosmos DB для NoSQL).

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

Примечание.

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

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

  • Доступ к рабочей области в режиме лицензии емкости Fabric (или) режим пробной лицензии с разрешениями участника или более высокого уровня.
  • Доступ к учетной записи и базе данных NoSQL для Azure Cosmos DB.
  • База данных Azure Cosmos DB для NoSQL должна быть общедоступной, а не за брандмауэром или защищенной в виртуальной сети.
  • Если у вас нет потока событий, создайте поток событий.

Получение сведений о подключении из портал Azure

Метки для элементов, которые необходимо собрать из портал Azure, показаны на следующих шагах. Вам всегда нужен универсальный код ресурса (URI) конечной точки( например https://<account>.<api>.azure.com:<port>/, первичный ключ и идентификаторы элементов базы данных, для которого требуется собирать данные.

Примечание.

Azure Cosmos DB для NoSQL CDC использует последний режим версии канала изменений Azure Cosmos DB. Он фиксирует изменения записей в последней версии. Обратите внимание, что удаления не записываются в этом режиме.

  1. На странице портал Azure учетной записи Azure Cosmos DB выберите "Ключи" в разделе "Параметры" в области навигации слева.

  2. На странице "Ключи" скопируйте URI и значения первичного ключа, которые будут использоваться для настройки подключения к потоку событий.

    Снимок экрана: URI и первичный ключ на странице ключей Azure Cosmos DB в портал Azure.

  3. На странице обзора портал Azure учетной записи Azure Cosmos DB запишите идентификатор базы данных и элемента, для которого требуется собрать данные.

    Снимок экрана: список контейнеров для учетной записи API NoSQL Azure Cosmos DB.

Примечание.

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

Добавление Azure Cosmos DB (CDC) в качестве источника

Если вы еще не добавили источник в поток событий, выберите "Использовать внешнюю плитку источника ".

Снимок экрана: выбор плитки

Если вы добавляете источник в уже опубликованный поток событий, перейдите в режим редактирования, выберите "Добавить источник" на ленте и выберите "Внешние источники".

Снимок экрана: выбор источника в меню  

На странице "Выбор источника данных" найдите и выберите "Подключиться" на плитке Центры событий Azure.

Снимок экрана: выбор Azure Cosmos DB (CDC) в качестве исходного типа в мастере выбора источника данных.

Настройка и подключение к Azure Cosmos DB (CDC)

  1. На экране "Подключение" в разделе "Подключение" выберите "Создать подключение", чтобы создать связывание облака с базой данных Azure Cosmos DB.

    Снимок экрана: страница

  2. На экране параметров подключения введите следующие сведения:

    • Конечная точка Cosmos DB: введите URI или конечную точку для учетной записи Cosmos DB, скопированной из портал Azure.
    • Имя подключения: автоматически создано или введите новое имя для этого подключения.
    • Ключ учетной записи. Введите первичный ключ для учетной записи Azure Cosmos DB, скопированной из портал Azure.

    Снимок экрана: параметры подключения для источника CDC Azure Cosmos DB.

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

  4. Укажите следующие сведения для ресурсов Azure Cosmos DB и нажмите кнопку "Далее".

    • Идентификатор контейнера. Введите имя контейнера или таблицы Azure Cosmos DB, к которой требуется подключиться.

    • База данных. Введите имя базы данных Azure Cosmos DB.

    • Политика смещения: выберите, следует ли начинать чтение самых ранних или последних смещения, если фиксация отсутствует.

      Вы также можете изменить имя источника в разделе "Сведения о потоке" справа, нажав кнопку "Карандаш".

      Снимок экрана: сведения о подключении для источника CDC в Azure Cosmos DB.

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

    Снимок экрана: страница проверки и подключения для источника CDC Azure Cosmos DB.

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

  1. Вы увидите источник Azure Cosmos DB (CDC), добавленный в поток событий в режиме редактирования. Выберите "Опубликовать" , чтобы опубликовать изменения и начать потоковую передачу данных CDC Azure Cosmos DB в поток событий.

    Снимок экрана: добавленный источник CDC Azure Cosmos DB в режиме редактирования с выделенной кнопкой

  2. Вы видите поток событий в режиме реального времени. Нажмите кнопку "Изменить " на ленте, чтобы вернуться в режим редактирования, чтобы обновить поток событий.

    Снимок экрана: опубликованный поток событий с источником Azure Cosmos DB в Режиме реального времени.

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

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