Интеграция с реестром схем в Azure Stream Analytics

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

В этой статье показано, как добавить реестр схем в задание Stream Analytics и подключиться к входным данным Центров событий.

Предпосылки

Перед началом работы убедитесь, что у вас есть следующее:

• Пространство имен Центров событий.
• Группа схем со схемами в реестре схем, размещённом центрами событий Azure. Создайте реестр схем Центров событий Azure , если у вас его нет.
• Задание Azure Stream Analytics с включенным управляемым удостоверением.

Управление доступом задания к реестру схем

Чтобы получить доступ к реестру схем Event Hubs, необходимо назначить роль читателя реестра схем заданию Stream Analytics с использованием принципала безопасности.

1. Войдите на портал Azure и перейдите на страницу задания Stream Analytics.

2. Выберите страницу Управляемое удостоверение и сохраните имя принципала для последующего использования. Дополнительные сведения см. в разделе "Управляемые удостоверения".

   

3. Перейдите на страницу пространства имен Event Hubs, где размещен реестр схем. Выберите "Управление доступом " и "Добавить назначение ролей".

   

4. Найдите средство чтения реестра схем и нажмите Далее.

   

5. На странице "Участники" выберите имя принципала, сохраненное на шаге 1, и нажмите "Проверить и назначить".

Добавление реестра схем в задание Stream Analytics

1. На портале заданий Stream Analytics выберите реестр схем в разделе "Параметры " в меню слева.
2. Выберите "Добавить реестр схем"
3. На странице "Новый реестр схем " выполните следующие действия.

   1. Имя, введите псевдоним для этого реестра схем.

   2. Для подписки выберите подписку с пространством имен Центров событий, где размещен реестр схем.

   3. Для пространства имен Центров событий выберите пространство имен, под которым находится реестр схем.

   4. Если у вас нет доступа к подписке, можно также использовать запись вручную.

      

Настройка входных данных Центров событий

1. Перейдите на страницу входных данных. Добавьте новые входные данные Центров событий или выберите существующие входные данные Центров событий.

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

3. Выберите AVRO для формата сериализации событий.

4. Выберите реестр схем в раскрывающемся меню и сохраните его.

   

Предварительный просмотр входных данных

Azure Stream Analytics автоматически извлекает события из входных данных потоковой передачи. Он предоставляет удобный способ проверки интеграции реестра схем без запуска или остановки задания.

1. На странице задания Stream Analytics выберите "Топология заданий" —> запрос , чтобы открыть окно редактора запросов.

2. Выберите настроенные входные данные Центров событий. Убедитесь, что рядом с выбранным входным данным есть значок файла.

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

   

Дополнительные сведения о тестировании запросов см. в разделе "Тестирование задания Azure Stream Analytics" с примерами данных .

Ограничения

1. Метод проверки подлинности реестра схем поддерживает только управляемое удостоверение. При выборе реестра схем метод проверки подлинности входных данных Центров событий должен быть управляемым удостоверением.
2. Функция тестового подключения пока недоступна для реестра схем. Лучший способ проверить подключение, созданное с помощью реестра схем, — это предварительная версия входных данных на странице тестирования запросов.

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

• Обработка данных из центров событий с помощью Azure Stream Analytics
• Тестирование задания Azure Stream Analytics с примерами данных