Azure Stream Analytics в IoT Edge (предварительная версия)
Azure Stream Analytics в IoT Edge помогает разработчикам развертывать решения аналитики ближе к устройствам Интернета вещей практически в реальном времени, что позволяет максимально эффективно использовать данные, полученные от устройств. Azure Stream Analytics предоставляет такие преимущества, как минимальная задержка, отказоустойчивость, эффективное использование пропускной способности и соответствие требованиям. Предприятия могут развертывать логику управления вблизи от промышленных объектов и дополнять выполняющийся в облаке анализ больших данных.
Azure Stream Analytics в IoT Edge работает на платформе Azure IoT Edge. Когда задание создано в Azure Stream Analytics, вы можете развертывать его и управлять им с помощью Центра Интернета вещей.
Распространенные сценарии
В этом разделе описаны распространенные сценарии для Stream Analytics в IoT Edge. На следующей схеме показан поток данных между устройствами IoT и облаком Azure.
Инструменты контроля и управление с низкой задержкой
Производственные системы безопасности должны реагировать на операционные данные со сверхнизкой задержкой. Используя Azure Stream Analytics в IoT Edge, вы можете анализировать данные датчиков практически в реальном времени, а также при обнаружении аномалий отдавать команды на остановку машины или активацию предупреждений.
Ограниченные возможности подключения к облаку
Критически важные системы, такие как оборудование для удаленного интеллектуального анализа данных, подключенные резервуары или оборудование для детализации данных внешней разработки, должны анализировать данные и реагировать на них, даже если подключение к облаку периодически прерывается. С Azure Stream Analytics логика потоковой передачи выполняется независимо от сетевого подключения, и вы можете выбирать, какие именно данные необходимо отправить в облако для дальнейшей обработки и хранения.
Ограниченная пропускная способность
Объем данных, создаваемых с помощью реактивных двигателей или подключенных автомобилей, может быть настолько большим, что данные необходимо отфильтровывать или предварительно обрабатывать, прежде чем отправить их в облако. Используя Azure Stream Analytics, можно отфильтровать или статистически обработать данные, которые необходимо передать в облако.
Соответствие нормативным требованиям
Для обеспечения соответствия нормативным требованиям может потребоваться локально анонимизировать или статистически обработать некоторые данные перед их отправкой в облако.
Задания Edge в службе Azure Stream Analytics
Задания Stream Analytics Edge выполняются в контейнерах, развернутых на устройствах Azure IoT Edge. Задания Edge состоят из двух частей:
Облачная часть, которая отвечает за определение задания: пользователи определяют входы, выходы, запросы и другие параметры, например неупорядоченные события, в облаке.
Модуль, выполняющийся на устройствах IoT Edge. Модуль содержит подсистему Stream Analytics и получает определение задания из облака.
Azure Stream Analytics развертывает задания Edge на устройствах с помощью Центра Интернета вещей. Дополнительные сведения см. в разделе Развертывание IoT Edge.
Ограничения для заданий Edge
Целью является обеспечение соответствия между заданиями IoT Edge и облачными заданиями. Большинство функций языка запросов SQL поддерживаются как в Edge, так и в облаке. Однако для заданий Edge не поддерживаются следующие компоненты:
- Определяемые пользователем функции (UDF) в JavaScript. Определяемые пользователем функции доступны в C# для заданий IoT Edge (предварительная версия).
- Определяемые пользователем статистические функции (UDA).
- Функции машинного обучения Azure.
- Формат AVRO для входных и выходных данных. На данный момент поддерживаются только форматы CSV и JSON.
- Следующие операторы SQL:
- PARTITION BY
- GetMetadataPropertyValue
- Политика для событий, сведения о которых поступают с задержкой
Требования к оборудованию и среде выполнения
Для запуска Azure Stream Analytics в IoT Edge вам потребуются устройства, которые могут работать в Azure IoT Edge.
В Azure Stream Analytics и Azure IoT Edge используются контейнеры Docker для предоставления переносимого решения, которое выполняется на нескольких ОС узла (Windows, Linux).
Служба Stream Analytics в IoT Edge доступна в качестве образов Windows и Linux, работающих под управлением архитектур x86–64 или ARM (Advanced RISC Machines).
Входные и выходные данные
Задания Stream Analytics Edge могут получать входные и выходные данные из других модулей, запущенных на устройствах IoT Edge. Чтобы подключиться к конкретным модулям и из них, можно задать конфигурацию маршрутизации во время развертывания. Дополнительные сведения см. в документации по композиции модуля IoT Edge.
Для входных и выходных данных поддерживаются форматы CSV и JSON.
Для каждого входного и выходного потока, создаваемого в задании Azure Stream Analytics, создается соответствующая конечная точка в развернутом модуле. Эти конечные точки можно использовать в маршрутах развертывания.
Поддерживаемые типы входных потоков:
- Центр Edge
- Центр событий
- Центр Интернета вещей
Поддерживаемые типы выходных потоков:
- Центр Edge
- База данных SQL
- Центр событий
- Хранилище BLOB-объектов/ADLS 2-го поколения
Эталонные входные данные поддерживают тип эталонного файла. Другие выходные данные можно получить с использованием подчиненного облачного задания. Например, задание Stream Analytics, размещенное в Edge, отправляет выходные данные в концентратор Edge, который затем может отправлять их в Центр Интернета вещей. Вы можете использовать второе облачное приложение Azure Stream Analytics с входными данными из Центра Интернета вещей и выходными данными в Power BI или другими типами данных.
Уведомления о лицензии и сторонних производителях
- Лицензия Azure Stream Analytics на IoT Edge.
- Уведомление сторонних производителей для Azure Stream Analytics на IoT Edge.
Сведения об образе модуля Azure Stream Analytics
Сведения о версии были обновлены 21.09.2020:
Изображение:
mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-amd64- базовый образ: mcr.microsoft.com/dotnet/core/runtime:2.1.13-alpine
- Платформы:
- архитектура: amd64
- ОС: Linux
Изображение:
mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-arm32v7- базовый образ: mcr.microsoft.com/dotnet/core/runtime:2.1.13-bionic-arm32v7
- Платформы:
- архитектура: arm
- ОС: Linux
Изображение:
mcr.microsoft.com/azure-stream-analytics/azureiotedge:1.0.9-linux-arm64- базовый образ: mcr.microsoft.com/dotnet/core/runtime:3.0-bionic-arm64v8
- Платформы:
- архитектура: arm64
- ОС: Linux
Получить помощь
Для получения дополнительной помощи воспользуйтесь страницей вопросов и ответов об Azure Stream Analytics.