Поделиться через

Запуск задания Azure Stream Analytics

  • Статья

Можно запустить задание Azure Stream Analytics с помощью портала Azure, Visual Studio или PowerShell. При запуске задания выбирается время, когда задание начнет создавать выходные данные. В портале Azure, Visual Studio и PowerShell существуют различные методы настройки времени начала. Эти методы описаны ниже.

Параметры запуска

Для запуска задания доступны три следующих варианта. Обратите внимание, что все указанные ниже значения времени указаны в параметре МЕТКА ВРЕМЕНИ ПО. Если значение МЕТКА ВРЕМЕНИ ПО не указано, будет использоваться время прибытия.

  • Сейчас. Создает начальную точку потока событий вывода, совпадающую с запуском задания. Если используется темпоральный оператор (например, временное окно, LAG или JOIN), Azure Stream Analytics будет автоматически искать данные в источнике входных данных. Например, если задание запускается "Сейчас" и в запросе используется 5-минутное "переворачивающееся"окно, Azure Stream Analytics будет искать входные данные, полученные 5 минут назад. Первое возможное событие вывода будет иметь метку времени, равную или больше текущего времени, а ASA гарантирует, что учитываются все входные события, которые могут логически участвовать в выходных данных. Например, частично обработанные статистические выражения не создаются. Это всегда полное статистическое значение.

  • Настраиваемое. Можно выбрать начальную точку вывода. Аналогично варианту Сейчас Azure Stream Analytics будет автоматически считывать данные до этого времени, если используется темпоральный оператор.

  • Во время последней остановки. Этот вариант доступен, если задание было запущено ранее, но было остановлено вручную или в результате ошибки. При выборе этого варианта Azure Stream Analytics будет использовать время последнего вывода для перезапуска задания, чтобы данные не были потеряны. Аналогично предыдущим вариантам Azure Stream Analytics будет автоматически считывать данные до этого времени, если используется темпоральный оператор. Так как несколько входных секций могут иметь разное время, используется самое раннее время для всех секций, в результате чего в выходных данных может появиться несколько дубликатов. Дополнительные сведения об однократной обработке доступны на странице гарантии доставки событий.

Портал Azure

Перейдите к своему заданию в портале Azure и нажмите кнопку Запуск на странице обзора. Выберите Время начала вывода задания, а затем нажмите кнопку Запуск.

Выберите один из вариантов времени запуска создания выходных данных задания. Доступны такие варианты, как Сейчас, Настраиваемое и, если задание было запущено ранее, При прошлой остановке. Дополнительные сведения об этих параметрах см. выше.

Visual Studio

В представлении задания нажмите кнопку с зеленой стрелкой, чтобы запустить задание. Задайте Режим начала вывода задания и нажмите кнопку Запуск. Состояние задания изменяется на Выполняется.

Существует три варианта режима начала вывода задания: JobStartTime, CustomTime и LastOutputEventTime. Если свойство отсутствует, значение по умолчанию — JobStartTime. Дополнительные сведения об этих параметрах см. выше.

PowerShell

Используйте следующий командлет для запуска задания с помощью PowerShell:

Start-AzStreamAnalyticsJob `
  -ResourceGroupName $resourceGroup `
  -Name $jobName `
  -OutputStartMode 'JobStartTime'

Существует три варианта OutputStartMode: JobStartTime, CustomTime и LastOutputEventTime. Если свойство отсутствует, значение по умолчанию — JobStartTime. Дополнительные сведения об этих параметрах см. выше.

Дополнительные сведения о командлете Start-AzStreamAnalyitcsJob см. в справочнике по Start-AzStreamAnalyticsJob.

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