Отладка на основе данных с помощью схемы заданий

  • Статья

Схема заданий в колонке Мониторинг на портале Azure может вам помочь визуализировать конвейер заданий. На ней представлены сведения о входных и выходных данных, а также о шагах запроса. С помощью схемы заданий можно проанализировать метрики на каждом шаге, чтобы быстро выявить источник проблемы при устранении неполадок.

Использование схемы заданий

На портале Azure в задании Stream Analytics в разделе Поддержка и устранение неполадок выберите Схема заданий:

Job diagram with metrics - location

Выберите каждый шаг запроса, чтобы отобразить соответствующий раздел в области изменения запроса. В нижней области на странице отображается диаграмма метрик для шага.

Job diagram with metrics - basic job

Для просмотра разделов входных данных Центров событий Azure выберите . . . Появится контекстное меню. Кроме того, отобразится инструмент слияния входных данных.

Job diagram with metrics - expand partition

Чтобы просмотреть схему с метриками для одного раздела, выберите его узел. Метрики отображаются в нижней части страницы.

Job diagram with metrics - more metrics

Чтобы увидеть схему метрик для слияния, выберите узел слияния. На следующей схеме видно, что события не были удалены или скорректированы.

Job diagram with metrics - grid

Чтобы просмотреть значения метрик и время, наведите указатель мыши на схему.

Job diagram with metrics - hover

Устранение неполадок с помощью метрик

Метрика QueryLastProcessedTime указывает, на каком конкретном шаге были переданы данные. Учитывая топологию, вы можете проанализировать обратный процесс выполнения (начиная от обработчика выходных данных), чтобы понять, на каком шаге данные не передаются. Если данные на шаге не передавались, перейдите к шагу запроса перед текущим шагом. Проверьте, задано ли на предыдущем шаге запроса временное окно и достаточно ли было времени для вывода данных. Учтите, что временные окна имеют почасовую привязку.

Если на предыдущем этапе не обрабатываются входящие данные, используйте входные метрики, чтобы получить ответ на следующие вопросы о заданиях, получающих данные из источников входных данных. Если запрос разделен, проверьте каждый раздел.

Какой объем данных считывается?

  • InputEventsSourcesTotal содержит число прочитанных единиц данных, например больших двоичных объектов.
  • Метрика InputEventsTotal содержит число прочитанных событий. Эта метрика доступна для каждого раздела.
  • Метрика InputEventsInBytesTotal содержит число прочитанных байтов.
  • Метрика InputEventsLastArrivalTime обновляется после размещения в очереди каждого полученного события.

Отсчитывается ли время? Если фактические события считываются, знаки препинания могут быть опущены.

  • Метрика InputEventsLastPunctuationTime указывает, когда знаки препинания используются для отсчета времени. Поток данных может быть заблокирован, если знаки препинания будут опущены.

Есть ли ошибки во входных данных?

  • Метрика InputEventsEventDataNullTotal содержит число событий со значением null.
  • Метрика InputEventsSerializerErrorsTotal содержит число событий, десериализацию которых удалось выполнить правильно.
  • Метрика InputEventsDegradedTotal содержит число событий, в которых возникла ошибка, не связанная с десериализацией.

Были ли события удалены или скорректированы?

  • Метрика InputEventsEarlyTotal содержит число событий с меткой времени для приложения до верхнего предела.
  • Метрика InputEventsLateTotal содержит число событий с меткой времени для приложения после верхнего предела.
  • Метрика InputEventsDroppedBeforeApplicationStartTimeTotal содержит число событий, удаленных до начала выполнения задания.

Есть ли непрочитанные данные?

  • Метрика Итого отложенных входных событий сообщает, сколько сообщений должен прочитать концентратор событий, и указывает входные данные Центра Интернета вещей Azure. Если это число больше 0, это означает, что задание не может обработать данные по мере их поступления. В таком случае попробуйте увеличить число единиц потоковой передачи и (или) проверьте, может ли задание выполняться параллельно. Дополнительные сведения см. на странице о параллелизации запросов.

Получить помощь

Для получения дополнительной помощи воспользуйтесь страницей вопросов и ответов о Microsoft Azure Stream Analytics.

Следующие шаги