Обработка данных из концентратора событий с помощью Azure Stream Analytics
Служба Azure Stream Analytics упрощает прием, обработку и анализ потоковой передачи данных из Центров событий Azure, позволяя получать эффективные аналитические данные для выполнения действий в реальном времени. Вы можете использовать портал Azure для визуализации входящих данных и создания запроса Stream Analytics. Когда запрос будет готов, его можно переместить в рабочую среду, всего несколько раз щелкнув мышью.
Основные преимущества
Ниже приведены основные преимущества Центров событий Azure и интеграции Azure Stream Analytics.
- Предварительный просмотр данных. Можно просмотреть входящие данные из концентратора событий на портале Azure.
- Тестирование запроса. Подготовка запроса преобразования и его тестирование непосредственно на портале Azure. Синтаксис языка запросов см. в документации по языку запросов Azure Stream Analytics.
- Развертывание запроса в рабочей среде. Можно развернуть запрос в рабочей среде, создав и запустив задание Azure Stream Analytics.
Полный поток процесса
Важно!
Если вы не имеете роль Владелец или Участник на уровне подписки Azure, вам потребуется роль Тестировщик запросов Stream Analytics на уровне подписки Azure, чтобы успешно выполнить описанные в этом разделе действия. Эта роль позволяет выполнять тестирование запросов, не создавая специального задания Stream Analytics. Инструкции по назначению роли пользователю см. в этой статье.
Войдите на портал Azure.
Перейдите к пространству имен Центров событий и перейдите к концентратору событий, который содержит входящие данные.
Выберите Обработка данных на странице концентратора событий или обработка данных в меню слева.
Выберите Пуск на плитке Включить аналитику в режиме реального времени из событий .
Отобразится страница запроса со значениями, уже заданными для следующих полей:
Концентратор событий в качестве входных данных для запроса.
Пример запроса SQL с оператором SELECT.
Выходной псевдоним для ссылки на результаты теста запроса.
Примечание
При первом использовании этой функции эта страница запрашивает разрешение на создание группы потребителей и политику для концентратора событий для предварительного просмотра входящих данных.
Выберите Создать на панели Просмотр входных данных, как показано на предыдущем рисунке.
На этой вкладке сразу же появится snapshot последних входящих данных.
Тип сериализации в данных определяется автоматически (JSON/CSV). Вы можете вручную изменить его на JSON/CSV/AVRO.
Вы можете просмотреть входящие данные в формате таблицы или необработанном формате.
Если данные не актуальны, выберите Refresh (Обновить), чтобы просмотреть последние события.
Ниже приведен пример данных в табличном формате:
Ниже приведен пример данных в необработанном формате:
Выберите Тестовый запрос, чтобы просмотреть моментальный снимок результатов тестирования запроса на вкладке Результаты теста. Вы также можете скачать эти результаты.
Напишите собственный запрос для преобразования данных. См. Справочник по языку запросов Stream Analytics.
После тестирования запроса и его перемещения в рабочую среду выберите Создать задание Stream Analytics.
На странице Новое задание New Stream Analytics сделайте следующее:
Укажите имя задания.
Выберите подписку Azure , в которой будет создано задание.
Выберите группу ресурсов для ресурса задания Stream Analytics.
Выберите расположение для задания.
В поле Имя политики Центров событий создайте новую политику или выберите существующую.
Для группы потребителей Центров событий создайте новую группу потребителей или выберите существующую группу потребителей.
Выберите Создать , чтобы создать задание Stream Analytics.
Примечание
Рекомендуется создавать группу потребителей и политику для каждого нового задания Azure Stream Analytics, которое вы будете создавать на странице "Центры событий". Группы потребителей допускают только пять одновременных средств чтения, поэтому для каждого задания выделяется выделенная группа потребителей, что позволяет избежать ошибок, которые могут возникнуть из-за превышения этого ограничения. Выделенная политика позволяет поворачивать ключ или отзывать разрешения без влияния на другие ресурсы.
Теперь ваше задание Stream Analytics создано, запрос прошел проверку, а входные данные здесь — это концентратор событий.
Добавьте выходные данные по своему выбору.
Вернитесь на страницу задания Stream Analytics, щелкнув имя задания в ссылке навигации.
Выберите Изменить запрос над окном Запрос .
Обновите
[OutputAlias]имя выходных данных и щелкните Сохранить ссылку запроса над запросом. Закройте страницу Запрос, выбрав X в правом верхнем углу.Теперь на странице задания Stream Analytics нажмите кнопку Пуск на панели инструментов, чтобы запустить задание.
Access
Проблема . Пользователь не может получить доступ к данным предварительного просмотра, так как у него нет необходимых разрешений на подписку.
Способ 1. Пользователь, который хочет предварительно просмотреть входящие данные, должен быть добавлен в качестве участника в подписке.
Способ 2. Пользователь должен быть добавлен с ролью тестировщика запросов Stream Analytics в подписке. Перейдите к управлению доступом для подписки. Добавьте новое назначение роли "тестировщик запросов Stream Analytics" для пользователя.
Способ 3. Пользователь может создать задание Azure Stream Analytics. Задайте входные данные в качестве этого концентратора событий и перейдите в раздел "Запрос", чтобы просмотреть входящие данные из этого концентратора событий.
Способ 4. Администратор может создать настраиваемую роль в подписке. Добавьте следующие разрешения для настраиваемой роли, а затем добавьте пользователя в новую настраиваемую роль.
Единицы потоковой передачи
В задании Azure Stream Analytics по умолчанию используются три единицы потоковой передачи. Чтобы настроить этот параметр, выберите Масштаб в меню слева на странице Задание Stream Analytics на портале Azure. Дополнительные сведения о единицах потоковой передачи см. в разделе Знакомство с единицами потоковой передачи и их настройка.
Дальнейшие действия
Дополнительные сведения о запросах Stream Analytics см. в разделе Язык запросов Stream Analytics.