Краткое руководство по созданию задания Stream Analytics с помощью портала Azure

В этом кратком руководстве вы создадите задание Stream Analytics в портал Azure. Вы определяете задание Stream Analytics, которое считывает данные потоковой передачи в режиме реального времени и фильтрует сообщения с температурой больше 27. Задание Stream Analytics считывает данные из Центр Интернета вещей, преобразует данные и записывает выходные данные в контейнер в хранилище BLOB-объектов Azure. Входные данные, используемые в этом кратком руководстве, создаются онлайн-симулятором Raspberry Pi.

Необходимые компоненты

Если у вас еще нет подписки Azure, создайте бесплатную учетную запись.

Подготовка входных данных

Прежде чем определить задание Stream Analytics следует подготовить входные данные. Данные датчиков в реальном времени принимаются в Центр Интернета вещей, который позже будет настроен как входные данные задания. Чтобы подготовить входные данные, необходимые для задания, выполните следующие действия:

1. Войдите на портал Azure.

2. Выберите Создать ресурс. На странице Создание ресурса выберите Интернет вещей>Центр Интернета вещей.

   

3. На странице Центр Интернета вещей сделайте следующее:

   1. Подписка — выберите подписку Azure.
   2. В качестве группы ресурсов выберите существующую группу ресурсов или создайте новую.
   3. В качестве имени центра Интернета вещей введите имя своего центра Интернета вещей.
   4. В качестве региона выберите ближайший к вам регион.
   5. для уровня выберите "Бесплатный", если он по-прежнему доступен в вашей подписке. Дополнительные сведения см. на странице цен на Центр Интернета вещей Azure.
   6. Для ограничения ежедневного сообщения сохраните значение по умолчанию.
   7. В нижней части страницы нажмите кнопку Далее: сети.

   

4. Выберите Review + create (Просмотреть и создать). Просмотрите сведения Центр Интернета вещей и нажмите кнопку "Создать". Создание Центра Интернета вещей может занять несколько минут. Ход создания можно отслеживать на панели уведомлений.

5. После создания ресурса (центра Интернета вещей) выберите Перейти к ресурсу, чтобы перейти на страницу "Центр Интернета вещей".

6. На странице Центр Интернета вещей выберите Устройства в меню слева и нажмите кнопку + Добавить устройство.

   

7. Введите идентификатор устройства и нажмите кнопку "Сохранить".

   

8. После создания устройство отобразится в списке устройств Интернета вещей. Нажмите кнопку Обновить на странице, если оно не отображается.

   

9. Выберите устройство из списка.

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

    

Запуск IoT-симулятора

1. Откройте онлайн-симулятор Raspberry Pi для Интернета вещей Azure.

2. Замените значения заполнителя в 15 строке строкой подключения устройства Центра Интернета вещей, которую вы сохранили при работе с предыдущим разделом.

3. Выберите Выполнить. В выходных данных должны присутствовать показания датчика и сообщения, отправляемые в Центр Интернета вещей.

   

Создание хранилища BLOB-объектов

1. В левом верхнем углу портал Azure выберите "Создать ресурс". Выберите хранилище в разделе "Категории " в меню слева и выберите учетную запись хранения.

2. В области создания учетной записи хранения введите имя для учетной записи хранения, расположение и группу ресурсов. Выберите такое же расположение и группу ресурсов, как и для созданного Центра Интернета вещей. Затем выберите "Рецензирование " в нижней части страницы.

   

3. На странице Проверка просмотрите параметры и выберите Создать, чтобы создать учетную запись.

4. После создания ресурса выберите Перейти к ресурсу, чтобы перейти на страницу Учетная запись хранения.

5. На странице Учетная запись хранения выберите Контейнеры в меню слева, а затем выберите + Контейнер.

   

6. На странице Новый контейнер укажите имя контейнера, например container1, и нажмите кнопку Создать.

   

Создание задания Stream Analytics

1. На отдельной вкладке того же окна браузера или в отдельном окне браузера войдите на портал Azure.

2. В меню слева выберите Все службы. Выберите "Аналитика" в разделе "Категории". Наведите указатель мыши на задания Stream Analytics и выберите или нажмите + кнопку " + Создать " во всплывающем окне.

   

3. На странице Новое задание New Stream Analytics сделайте следующее:

   1. Подписка — выберите подписку Azure.

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

   3. В качестве имени введите имя задания. Имя задания Stream Analytics может содержать только буквенно-цифровые символы, дефисы и знаки подчеркивания. Длина должна составлять от 3 до 63 символов.

   4. В качестве среды размещения выберите значение Облако. Задания Stream Analytics можно развернуть в облаке или на граничных устройствах. Значение "Облако" позволяет выполнять развертывание в облаке Azure, а Edge — на устройстве IoT Edge.

   5. В качестве единиц потоковой передачи выберите 1. Единица потоковой передачи предоставляет вычислительные ресурсы, которые необходимы для выполнения задания. Чтобы узнать о масштабировании единиц потоковой передачи, ознакомьтесь со статьей Обзор и настройка единиц потоковой передачи.

   6. В нижней части страницы выберите Review + create (Проверить и создать).

      

4. На странице Просмотр и создание проверьте параметры и выберите Создать, чтобы создать страницу Stream Analytics.

5. На странице развертывания выберите Перейти к ресурсу, чтобы перейти на страницу Задание Stream Analytics.

Настройка входных данных для задания

В этом разделе описана настройка входных данных устройства Центр Интернета вещей для задания Stream Analytics. Используйте Центр Интернета вещей, созданный в предыдущем разделе краткого руководства.

1. На странице задания Stream Analytics выберите входные данные в разделе топологии заданий в меню слева.

2. На странице "Входные данные" выберите "Добавить входные данные> Центр Интернета вещей".

   

3. На странице Центр Интернета вещей сделайте следующее:

   1. В качестве псевдонима ввода введите IoTHubInput.

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

   3. В качестве Центра Интернета вещей выберите свой центр Интернета вещей.

   4. Нажмите кнопку Сохранить, чтобы сохранить входные параметры для задания Stream Analytics.

      

Настройка выходных данных для задания

1. Теперь выберите Выходные данные в разделе Топология задания в меню слева.

2. На странице "Выходные данные" выберите "Добавить выходное>хранилище BLOB-объектов/ADLS 2-го поколения".

   

3. На странице Новые выходные данные для хранилища BLOB-объектов/ADLS 2-го поколения сделайте следующее:

   1. В качестве псевдонима выходных данных введите BlobOutput.

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

   3. В качестве учетной записи хранения выберите свою учетную запись хранения.

   4. В качестве контейнера выберите контейнер BLOB-объектов, если он еще не выбран.

   5. В качестве режима аутентификации выберите вариант Строка подключения.

   6. Выберите Сохранить в нижней части страницы, чтобы сохранить параметры выходных данных.

      

Определение запроса преобразования

1. Теперь выберите Запрос в разделе Топология задания в меню слева.

2. Введите следующий запрос в окно запроса. В этом примере выполняется запрос на считывание данных из Центра Интернета вещей. Затем данные копируются в новый файл в BLOB-объекте.

   SELECT *
   INTO BlobOutput
   FROM IoTHubInput
   WHERE Temperature > 27
   

3. На панели инструментов выберите Сохранить запрос.

   

Запуск задания Stream Analytics и просмотр выходных данных

1. Вернитесь на страницу обзора задания в портал Azure и нажмите кнопку "Пуск задания".

   

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

   

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

   

4. Выберите файл, а затем на странице BLOB-объект нажмите кнопку Изменить, чтобы просмотреть содержимое файла.

   

Очистка ресурсов

Ставшие ненужными группу ресурсов, задание Stream Analytics и все связанные ресурсы можно удалить. При удалении задания будет прекращена тарификация за единицы потоковой передачи, потребляемые заданием. Если вы планируете использовать это задание в будущем, вы можете остановить и перезапустить его позже. Если вы не собираетесь использовать это задание дальше, удалите все ресурсы, созданные в ходе работы с этим руководством, сделав следующее:

1. В меню слева на портале Azure выберите Группы ресурсов, а затем выберите имя созданного ресурса.
2. На странице группы ресурсов выберите Удалить, в текстовом поле введите имя ресурса для удаления и щелкните Удалить.
3. В приложении Симулятора Raspberry Pi Azure IoT Online нажмите кнопку "Сброс" рядом с кнопкой "Запустить" в нижней области справа.

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

Дополнительные сведения о настройке других источников входных данных и обнаружении в режиме реального времени см. в следующей статье:

Приступая к работе с Azure Stream Analytics: выявление мошенничества в режиме реального времени