Быстрый старт: создание задания Azure Stream Analytics при помощи Visual Studio

В этом кратком руководстве показано, как создать и запустить задание Stream Analytics с помощью средств Azure Stream Analytics для Visual Studio. Пример задания считывает потоковые данные с устройства Центра Интернета вещей. Вы определяете задание, которое вычисляет среднюю температуру при более чем 27° и записывает полученные выходные события в новый файл в хранилище BLOB-объектов.

Замечание

• Мы настоятельно рекомендуем использовать средства Stream Analytics для Visual Studio Code для наилучшего опыта локальной разработки. Существуют известные пробелы функций в средствах Stream Analytics для Visual Studio 2019 (версия 2.6.3000.0), и она не будет улучшена.
• Средства Visual Studio и Visual Studio Code не поддерживают рабочие места в регионах "Восточная Китай", "Северная Часть Китая", "Центральная Германия" и "Северная Германия".

Перед тем как начать

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

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

• Установите Visual Studio 2019, Visual Studio 2015 или Visual Studio 2013 с обновлением 4. Поддерживаются выпуски Enterprise (Ultimate/Premium), Professional и Community. Выпуск Express не поддерживается.

• Следуйте инструкциям по установке средств Stream Analytics для Visual Studio.

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

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

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

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

3. В области IoT Hub введите следующие сведения:

   Настройки	Рекомендуемое значение	Описание
   Subscription	<Подписка>	Выберите подписку Azure, которую нужно использовать.
   Группа ресурсов	asaquickstart-resourcegroup	Выберите "Создать" и введите новое имя группы ресурсов для учетной записи.
   Имя Центра Интернета вещей	MyASAIoTHub	Выберите имя центра Интернета вещей.
   Регион	<Выберите регион, ближайший к пользователям>	Выберите географическое расположение, в котором можно разместить Центр Интернета вещей. Используйте расположение, ближайшее к пользователям.
   Тир	Бесплатно	В этом кратком руководстве выберите "Бесплатный", если этот вариант по-прежнему доступен в вашей подписке. Если уровень "Бесплатный" недоступен, выберите самый низкий уровень. Дополнительные сведения см. в разделе цен на Центр Интернета вещей.

   

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

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

6. На странице Центра Интернета вещей выберите "Устройства" в меню навигации слева.

7. На странице "Устройства" выберите +Добавить устройство на панели инструментов.

   

8. На странице "Создание устройства" введите имя устройства и нажмите кнопку "Сохранить".

   

9. После создания устройства откройте устройство из списка устройств Интернета вещей . Если устройство еще не отображается, обновите страницу.

   

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

Создание BLOB-хранилища

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

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

   

3. После создания учетной записи хранения выберите плитку службы BLOB на панели Обзор.

   

4. На странице службы Blob выберите + Контейнер на панели инструментов.

5. На странице "Создать контейнер " введите имя контейнера, например container1. Оставьте общедоступный уровень доступакак частный (без анонимного доступа) и нажмите кнопку "Создать".

   

Создание проекта Stream Analytics

1. Запустите Visual Studio.

2. Выберите Файл > Создать проект.

3. В списке шаблонов слева выберите Stream Analytics и выберите приложение Azure Stream Analytics.

4. Введите имя проекта, расположение и имя решения и нажмите кнопку "Создать".

   

5. Обратите внимание на элементы, включенные в проект Azure Stream Analytics.

   

Выбор требуемой подписки

1. В Visual Studio в меню "Вид " выберите обозреватель серверов.
2. Щелкните правой кнопкой мыши Azure, выберите "Подключиться к подписке Microsoft Azure" и войдите с помощью учетной записи Azure.

Определение входных данных

1. В обозревателе решений разверните узел входных данных и дважды щелкните Input.json.

2. Заполните конфигурацию входных данных Stream Analytics следующими значениями:

   Настройки	Рекомендуемое значение	Описание
   Псевдоним входных данных	Ввод	Введите имя для идентификации входных данных задания.
   Тип источника	Поток данных	Выберите соответствующий источник входных данных: поток данных или справочные данные.
   Исходный материал	IoT Hub	Выберите соответствующий источник входных данных.
   Resource	Выбор источника данных из текущей учетной записи	Выберите ввод данных вручную или выберите существующую учетную запись.
   Subscription	<Подписка>	Выберите подписку Azure, в которой вы создали Центр Интернета вещей.
   IoT Hub	MyASAIoTHub	Выберите или введите имя Центра Интернета вещей. Имена Центров Интернета вещей автоматически определяются, если они созданы в рамках одной подписки.

3. Оставьте другие параметры значениями по умолчанию и нажмите кнопку "Сохранить ", чтобы сохранить параметры.

   

Определение выходных данных

1. В обозревателе решений разверните узел вывода и дважды щелкните Output.json.

2. Заполните конфигурацию выходных данных Stream Analytics следующими значениями:

   Настройки	Рекомендуемое значение	Описание
   Псевдоним выходных данных	Выходные данные	Введите имя для обозначения выходных данных задания.
   Тонуть	Хранилище Data Lake Storage Gen 2/Blob Storage	Выберите соответствующий приемник.
   Resource	Укажите параметры источника данных вручную	Выберите ввод данных вручную или выберите существующую учетную запись.
   Subscription	<Подписка>	Выберите подписку Azure с созданной учетной записью хранения. Учетная запись хранения может находиться в той же или другой подписке. В этом примере предполагается, что вы создали учетную запись хранения в той же подписке.
   Учетная запись хранения	asaquickstartstorage	Выберите или введите имя учетной записи хранения. Имена учетных записей хранения автоматически обнаруживаются, если они созданы в той же подписке.
   Контейнер	container1	Выберите существующий контейнер, созданный в учетной записи хранения.
   Шаблон пути	output	Введите имя пути к файлу, который нужно создать в контейнере.

3. Оставьте другие параметры значениями по умолчанию и нажмите кнопку "Сохранить ", чтобы сохранить параметры.

   

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

1. Откройте Script.asaql из обозревателя решений в Visual Studio.

2. Добавьте следующий запрос:

   SELECT *
   INTO Output
   FROM Input
   WHERE Temperature > 27
   

Отправка запроса Stream Analytics в Azure

1. В редакторе запросов выберите "Отправить в Azure" в редакторе скриптов.

2. В окне "Отправить задание " выберите "Создать задание Azure Stream Analytics".

3. Введите имя задания.

4. Выберите подписку Azure.

5. Выберите группу ресурсов.

6. Сохраните значение по умолчанию для кластера.

7. Выберите расположение, которое вы использовали в начале быстрого старта.

8. Затем нажмите кнопку "Отправить".

   

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

1. Откройте симулятор Raspberry Pi Azure IoT Online на новой вкладке браузера или окне.

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

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

   

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

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

   

2. Измените режим запуска выходных данных задания на JobStartTime и нажмите кнопку "Пуск".

   

3. Обратите внимание, что состояние задания изменилось на "Выполнение", и есть события ввода и вывода. Это может занять несколько минут. Нажмите кнопку "Обновить" на панели инструментов, чтобы обновить метрики.

   

4. Чтобы просмотреть результаты, в меню "Вид " выберите Cloud Explorer и перейдите к учетной записи хранения в группе ресурсов. В разделе "Контейнеры BLOB-объектов" дважды щелкните контейнер1, а затем на путь к файлу output.

   

Очистите ресурсы

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

1. В меню слева на портале Azure выберите группы ресурсов и выберите имя созданного ресурса.
2. На странице группы ресурсов выберите "Удалить", введите имя ресурса для удаления в текстовом поле и нажмите кнопку "Удалить".

Дальнейшие шаги

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

Чтобы узнать о средствах Azure Stream Analytics для Visual Studio, перейдите к следующей статье:

Просмотр заданий Azure Stream Analytics с помощью Visual Studio