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

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

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

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

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

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

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

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

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

   

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

   

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

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

   

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

   

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

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

   

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

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

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

   

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

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

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

   

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

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

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

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

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

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

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