Примечание.
Для доступа к этой странице требуется авторизация. Вы можете попробовать войти или изменить каталоги.
Для доступа к этой странице требуется авторизация. Вы можете попробовать изменить каталоги.
Задания Azure Stream Analytics подключаются к одному или нескольким источникам данных. Каждый вход определяет подключение к существующему источнику данных. Stream Analytics принимает данные из нескольких типов источников событий, включая Event Hubs, Центр Интернета вещей и хранилище Blob. Входные данные упоминаются по имени в потоковом SQL-запросе, который вы пишете для каждого задания. В запросе можно объединить несколько входных данных для слияния данных или сравнения потоковых данных с поисковыми таблицами для ссылки на данные и передать результаты на выход.
Stream Analytics имеет первоклассную интеграцию с четырьмя типами ресурсов в качестве входных данных:
- Центры событий Azure
- Центр Интернета вещей Azure
- Azure хранилище BLOB-объектов
- Azure Data Lake Storage 2-го поколения
- Apache Kafka
Эти входные ресурсы могут жить в той же Azure подписке, что и задание Stream Analytics или из другой подписки.
Вы можете использовать портал Azure, Azure PowerShell, .NET API, REST API, Visual Studio и Visual Studio Code для создания, изменения и тестирования входных данных заданий Stream Analytics.
Замечание
Используйте средства Stream Analytics для Visual Studio Code для лучшей локальной разработки. Средства Stream Analytics для Visual Studio 2019 (версия 2.6.3000.0) имеют известные пробелы функций и не будут улучшены.
Потоковые и ссылочные входные данные
При отправке данных в источник данных задание Stream Analytics использует данные и обрабатывает их в режиме реального времени. Входные данные делятся на два типа:
- Входные данные потока данных
- Эталонные данные ввода
Ввод потока данных
Поток данных — это несвязанная последовательность событий с течением времени. Задания Stream Analytics должны включать по крайней мере один входный поток данных. Центры событий, Центр Интернета вещей, Azure Data Lake Storage 2-го поколения и BLOB-хранилище поддерживаются в качестве источников входных данных потока данных. Центры событий собирают потоки событий из нескольких устройств и служб. Эти потоки могут включать каналы активности социальных сетей, сведения о торговле акциями или данные с датчиков. Центры Интернета вещей оптимизированы для сбора данных с подключенных устройств в сценариях Интернета вещей (IoT). Хранилище BLOB-объектов может получать массовые данные в виде потока, например файлы журнала.
Для получения дополнительной информации о входных данных потоковой передачи см. потоковые данные в качестве входных данных для Stream Analytics.
Ввод ссылочных данных
Stream Analytics также поддерживает входные данные, известные как эталонные данные. Эталонные данные являются полностью статическими или изменяются медленно. Обычно используется для выполнения корреляции и поиска. Например, вы можете присоединить данные в входных данных потока данных к данным в эталонных данных, а также выполнить соединение SQL для поиска статических значений. Azure хранилище BLOB-объектов, Azure Data Lake Storage 2-го поколения и База данных SQL Azure в настоящее время поддерживаются в качестве источников входных данных для эталонных данных. Блобы данных источника ссылок имеют ограничение размером до 300 МБ в зависимости от сложности запроса и выделенных Стриминговых единиц. Дополнительные сведения см. в разделе ограничения размера документации по эталонным данным.
Дополнительные сведения о входных данных ссылочных данных см. в статье «Использование ссылочных данных для поиска в Stream Analytics».