Перемещение данных с помощью Stream Analytics
Azure Stream Analytics — это обработчик обработки событий в режиме реального времени, предназначенный для обработки данных быстрой потоковой передачи из нескольких источников одновременно. Она может выполнять статистическую обработку, анализ, преобразование и даже перемещение данных в другие хранилища для более глубокого дополнительного анализа.
Настройка
Azure Stream Analytics поддерживает несколько приемников выходных данных, включая Azure Cosmos DB для NoSQL.
Примечание.
По состоянию на этот раз поддерживается только API NoSQL.
Настройка
Настройка выходных данных Azure Cosmos DB для NoSQL состоит из выбора учетной записи в подписке или предоставления учетных данных, которые обычно включают:
| Свойство | Описание |
|---|---|
Output alias |
Псевдоним для ссылки на эти выходные данные в запросе |
Account ID |
URI конейной точки учетной записи |
Account Key |
Ключ учетной записи |
Database |
Имя ресурса базы данных |
Container name |
Имя контейнера |
База данных и контейнер уже должны существовать в учетной записи Azure Cosmos DB для NoSQL перед использованием приемника выходных данных.
Запись в Azure Cosmos DB
Результаты запроса из Azure Stream Analytics будут обрабатываться в виде выходных данных JSON при записи в Azure Cosmos DB для NoSQL.
Кроме того, элементы добавляются в Azure Cosmos DB для NoSQL на основе значения поля идентификатора. Элементы обычно вставляются в Azure Cosmos DB для NoSQL. Если элемент уже существует с тем же уникальным идентификатором, то операция считается операцией обновления вместо операции вставки .