Проверка задания Stream Analytics на портале
В Azure Stream Analytics запрос можно проверить без запуска или остановки задания. Вы можете тестировать запросы на входящие данные из источников потоковой передачи или отправлять примеры данных из локального файла на портал Azure. Вы также можете тестировать запросы локально на основе локальных примеров данных или динамических данных в Visual Studio и Visual Studio Code.
Автоматическая выборка входящих данных из входных данных
Azure Stream Analytics автоматически получает события из входных данных потоковой передачи. Запросы могут выполняться для стандартной выборки или конкретного заданного интервала времени выборки.
Войдите на портал Azure.
Найдите и выберите имеющееся задание Stream Analytics.
На странице задания Stream Analytics в разделе Топологии задания установите флажок Запрос, чтобы открыть окно редактора запросов.
Чтобы просмотреть пример списка входящих событий, выберите значок ввода с помощью файла, и примеры событий автоматически отобразятся в области Предпросмотр ввода.
a. Если тип сериализации данных — JSON или CSV, он определяется автоматически. Его также можно изменить вручную на JSON, CSV или AVRO, выбрав соответствующий параметр в раскрывающемся меню.
b. Воспользуйтесь селектором для просмотра данных в табличном или необработанном формате.
c. Если данные не актуальны, выберите Обновить, чтобы просмотреть последние события.
В таблице ниже приведен пример данных в табличном формате.
В таблице ниже приведен пример данных в необработанном формате.
Чтобы проверить запрос с входящими данными, выберите Тест запроса. Результаты отобразятся на вкладке Результаты теста. Их можно также скачать, выбрав Скачать результаты.
Нажмите Выбор диапазона времени, чтобы проверить запрос по определенному диапазону входящих событий.
Задайте диапазон времени для событий, которые вы хотите использовать для проверки запроса, и выберите Пример. В течение этого интервала времени можно получить до 1000 событий или 1 МБ, в зависимости от того, какое из этих значений будет достигнуто первым.
После выборки событий для выбранного периода времени эти события отображаются на вкладке Предпросмотр ввода.
Выберите Сброс, чтобы просмотреть список входящих событий в выборке. Если выбрать Сброс, выбор диапазона времени будет утрачен. Выберите Тест запроса для проверки запроса и просмотра результатов на вкладке Результаты теста.
После внесения изменений в запрос нажмите кнопку Сохранить запрос, чтобы проверить новую логику запроса. Это позволяет итеративно изменять запрос и проверять его повторно, чтобы увидеть, как изменяются выходные данные.
После проверки результатов, отображаемых в браузере, можно приступать к запуску задания.
Отправка примера данных из локального файла
Вместо динамических данных для проверки запроса Azure Stream Analytics можно использовать пример данных из локального файла.
Войдите на портал Azure.
Найдите имеющееся задание Stream Analytics и выберите его.
На странице задания Stream Analytics в разделе Топологии задания установите флажок Запрос, чтобы открыть окно редактора запросов.
Чтобы проверить запрос с помощью локального файла, выберите Отправить пример входных данных на вкладке Предпросмотр ввода.
Отправьте локальный файл для проверки запроса. Вы можете отправлять файлы только в форматах JSON, CSV и AVRO. Щелкните ОК.
Отправив файл, вы сможете просмотреть его содержимое в табличном или необработанном формате. Если выбрать Сброс, в качестве примера данных снова будут использоваться входящие данные, как описано в предыдущем разделе. Вы можете в любое время отправить другой файл для проверки запроса.
Выберите Тест запроса, чтобы проверить запрос для отправленного примера файла.
У соответствии с запросом отобразятся результаты теста. Вы можете изменить запрос и нажать кнопку Сохранить запрос для проверки его новой логики. Это позволяет итеративно изменять запрос и проверять его повторно, чтобы увидеть, как изменяются выходные данные.
Если для запроса используется несколько выходов, результаты отображаются в соответствии с выбранным выходом.
После проверки результатов, отображаемых в браузере, можно запустить задание.
Ограничения
При проверке на портале политика времени не поддерживается.
- Поступление не по порядку. Все входящие события будут расположены по порядку.
- Поступление с опозданием. Поступившие с опозданием события отсутствуют, так как Stream Analytics может использовать для тестирования только имеющиеся данные.
Определяемая пользователем функция C# не поддерживается.
Все проверки будут выполняться с заданием, имеющим одну единицу потоковой передачи.
Длительность времени ожидания — одна минута. Так что ни один запрос с размером окна больше одной минуты не сможет получить данные.
Машинное обучение не поддерживается.
API примера данных регулируется после пяти запросов в 15-минутном окне. По окончании 15-минутного окна можно выполнить дополнительные запросы примеров данных. Это ограничение применяется на уровне подписки.
Устранение неполадок
При возникновении этой ошибки "The request size is too big. Please reduce the input data size and try again" (Слишком большой размер запроса Сократите размер входных данных и повторите попытку) выполните следующие действия.
- Уменьшите размера входных данных. Проверьте запрос с примером файла меньшего размера или с меньшим диапазоном времени.
- Уменьшите размер запроса. Чтобы проверить выбор запроса, выберите часть запроса, а затем щелкните Проверить выбранный запрос.
Дальнейшие действия
Создание решения IoT с помощью Stream Analytics. Из этого учебника вы узнаете, как создать комплексное решение с генератором данных, который будет имитировать трафик на пункте сбора оплаты.
Примеры запросов для распространенных шаблонов использования Stream Analytics