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

Добавление источника CDC Azure Cosmos DB в поток событий (предварительная версия)

  • Статья

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

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

Внимание

Расширенные возможности потоков событий Fabric в настоящее время находятся в предварительной версии.

Примечание.

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

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

  • Доступ к рабочей области Fabric premium с разрешениями участника или более высокого уровня.
  • Доступ к учетной записи и базе данных 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) в качестве источника

  1. В Службе "Аналитика в режиме реального времени" выберите eventstream , чтобы создать новый поток событий. Убедитесь, что включен параметр расширенных возможностей (предварительная версия ).

    Снимок экрана: создание нового потока событий.

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

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

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

  1. На экране "Выбор источника данных" выберите Azure Cosmos DB (CDC).

    Снимок экрана: выбор Azure Cosmos DB (CDC).

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

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

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

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

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

  5. Укажите следующие сведения для ресурсов Azure Cosmos DB:

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

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

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

  7. Просмотрите сводку и нажмите кнопку "Добавить".

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

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

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

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

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

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