Вывод данных из Azure Stream Analytics в Azure Cosmos DB

  • Статья

Azure Cosmos DB — это глобально распределенная служба базы данных, предоставляющая гибкое масштабирование без ограничений по всему миру, расширенные возможности запросов и автоматическое индексирование по моделям данных, не зависящим от схемы. Дополнительные сведения о параметрах контейнера Azure Cosmos DB для Stream Analytics см. в статье Stream Analytics с Azure Cosmos DB в качестве выходных данных.

Выходные данные Azure Cosmos DB из Stream Analytics в настоящее время недоступны в Microsoft Azure под управлением 21Vianet и Azure для Германии (T-Systems International).

Примечание

Azure Stream Analytics поддерживает подключение к Azure Cosmos DB только при помощи SQL API. Другие API Azure Cosmos DB в данный момент не поддерживаются. Если указать модулю Azure Stream Analytics учетные записи Azure Cosmos DB, созданные при помощи других API, это может привести к неправильному сохранению данных.

В следующей таблице описаны свойства для создания выходных данных Azure Cosmos DB.

Имя свойства Описание
Псевдоним выходных данных Псевдоним для ссылки на эти выходные данные в запросе Stream Analytics.
Приемник Azure Cosmos DB.
Вариант импорта Выберите Выбрать Azure Cosmos DB из подписки или Укажите параметры Azure Cosmos DB вручную.
Идентификатор учетной записи Имя или универсальный код ресурса (URI) конечной точки учетной записи Azure Cosmos DB.
Ключ учетной записи Общедоступный ключ доступа к учетной записи Azure Cosmos DB.
База данных Имя базы данных Azure Cosmos DB.
Имя контейнера Имя используемого контейнера, которое должно существовать в Azure Cosmos DB. Пример
  • MyContainer: Контейнер с именем "MyContainer" должен существовать.
Идентификатор документа Необязательный параметр. Имя поля в выходных событиях, используемое для указания первичного ключа, на котором основываются операции вставки или обновления.

Примечание

Выходные данные Azure Cosmos DB для Azure Stream Analytics используют пакет SDK для .NET версии 3. При записи в несколько регионов пакет SDK автоматически выбирает наилучший доступный регион.

Секционирование

Значение ключа секции основано на предложении PARTITION BY в запросе. Количество модулей записи выходных данных соответствует секционированию входных данных для полностью распараллеливаемых запросов. Stream Analytics преобразует ключ секции выходных данных Azure Cosmos DB в строку. Например, ключ секции со значением 1 типа bigint преобразуется в значение 1 типа string. Это преобразование всегда происходит независимо от того, записывается ли свойство секции в Azure Cosmos DB.

Размер выходного пакета

Сведения о максимальном размере сообщения см. в разделе Ограничения Azure Cosmos DB. Размер пакета и частота записи корректируются динамически с учетом ответов Azure Cosmos DB. Предопределенные ограничения для Stream Analytics отсутствуют.

Дальнейшие действия