Добавление источника событий и управление им в потоке событий
После создания потока событий его можно подключить к различным источникам данных и назначениям. К типам источников событий, которые можно добавить в поток событий, относятся Центры событий Azure, пример данных и пользовательское приложение. Дополнительные сведения об этих источниках событий см. в разделе Поддерживаемые источники событий.
Важно!
Microsoft Fabric в настоящее время находится на этапе предварительной версии. Эти сведения относятся к предварительной версии продукта, который может быть существенно изменен перед выпуском. Корпорация Майкрософт не дает никаких гарантий, явных или подразумеваемых, в отношении предоставленной здесь информации.
Предварительные требования
Чтобы приступить к работе, необходимо выполнить следующие предварительные требования.
- Получите доступ к рабочей области уровня "Премиум" с разрешениями участника или выше, в которой находится ваш поток событий.
- Для Центры событий Azure источника — концентратор событий Azure с данными о событиях и соответствующими разрешениями, доступными для доступа к его ключам политики.
Добавление концентратора событий Azure в качестве источника
Если у вас есть концентратор событий Azure, созданный с данными о событиях, выполните следующие действия, чтобы добавить концентратор событий Azure в качестве источника потока событий:
Выберите Новый источник на ленте или "+" на холсте редактора main, а затем Центры событий Azure.
Введите имя нового источника и выберите облачное подключение к концентратору событий Azure.
Если у вас нет подключения к облаку, выберите Создать новое подключение , чтобы создать его. Чтобы создать новое подключение, введите сведения о концентраторе событий Azure на странице Новое подключение .
Имя подключения. Введите имя облачного подключения.
Тип подключения: значение по умолчанию —
EventHub.Пространство имен концентратора событий. Введите имя пространства имен концентратора событий Azure.
Имя пользователя и пароль для проверки подлинности. Перейдите в концентратор событий Azure и создайте политику в разделе Общие политики доступа. Затем используйте имя политики и первичный ключ в качестве имени пользователя и пароля.
Уровень конфиденциальности: выберите уровень конфиденциальности для облачного подключения.
После создания подключения к облаку нажмите кнопку обновить и выберите созданное облачное подключение.
Выберите формат данных для входящих событий в режиме реального времени, которые вы хотите получить из концентратора событий Azure.
Примечание
Функция потоков событий поддерживает прием событий из Центры событий Azure в форматах данных JSON, Avro и CSV (с заголовком).
Выберите группу потребителей , которая используется для чтения данных о событиях из концентратора событий Azure, а затем нажмите кнопку Создать.
После создания источника концентратора событий вы увидите источник концентратора событий, добавленный в поток событий на холсте.
Добавление примера данных в качестве источника
Чтобы лучше понять, как работает поток событий, можно использовать встроенный пример данных и отправить данные в поток событий. Чтобы добавить пример источника данных, выполните следующие действия.
Выберите Новый источник на ленте или "+" на холсте редактора main, а затем — Пример данных.
В области справа введите имя источника, которое будет отображаться на холсте, выберите нужный пример данных для добавления в поток событий, а затем нажмите кнопку Создать.
Желтый такси: пример данных такси с предустановленной схемой, которая включает такие поля, как время отправки, время высадки, расстояние, общая плата и многое другое.
Фондовый рынок: образцы данных фондовой биржи с предустановленным столбцом схемы, таким как время, символ, цена, объем и многое другое.
После успешного создания примера источника данных его можно найти на холсте и в области навигации.
Чтобы проверить, успешно ли добавлен пример данных, выберите Предварительный просмотр данных в нижней области.
Добавление пользовательского приложения в качестве источника
Если вы хотите подключить собственное приложение к потоку событий, вы можете добавить его в качестве пользовательского источника приложения. Затем отправьте данные в поток событий с помощью собственного приложения с помощью конечной точки подключения, предоставленной в пользовательском приложении. Чтобы добавить пользовательский источник приложения, выполните следующие действия.
Выберите Новый источник на ленте или "+" на холсте редактора main, а затем — Пользовательское приложение.
Введите имя источника для настраиваемого приложения и нажмите кнопку Создать.
После успешного создания пользовательского приложения можно просмотреть сведения о пользовательском приложении, например строку подключения , в нижней области.
Строка подключения — это строка подключения, совместимая с концентратором событий , и ее можно использовать в приложении для отправки событий в поток событий.
Управление источником
Изменить и удалить. Вы можете выбрать источник потока событий для изменения или удаления с помощью области навигации или холста. При нажатии кнопки Изменить справа от редактора main откроется область редактирования.
Повторно создать ключ для пользовательского приложения. Если вы хотите повторно создать новый ключ подключения для приложения, выберите один из источников настраиваемых приложений на холсте и нажмите кнопку Повторно создать , чтобы получить новый ключ подключения.
Поддерживаемые источники событий
Используя источники потока событий, пользователи могут легко включать свои события в режиме реального времени в Microsoft Fabric, что облегчает эффективный и эффективный прием данных.
Примечание
- Общее число источников и назначений для одного потока событий равно 11.
- Хранение данных событий в потоке событий составляет 1 день с возможностью расширения и настройки в будущем.
В настоящее время доступны следующие источники.
Центры событий Azure
Если у вас уже есть концентратор событий Azure, вы можете использовать его для приема данных в режиме реального времени в Microsoft Fabric с помощью функции потоков событий.
Имя источника — понятное имя источника, которое отображается в потоке событий.
Подключение к облаку . Необходимо установить облачное подключение между существующим концентратором событий и Microsoft Fabric. После установки облачного подключения его можно повторно использовать в нескольких элементах потока событий. Чтобы создать новое облачное подключение, необходимо указать имя пространства имен концентратора событий, имя концентратора событий, имя политики общего доступа и первичный ключ.
Формат данных — формат входящих событий в режиме реального времени, которые вы хотите получить из концентратора событий Azure.
Группа потребителей — группа потребителей концентратора событий, которая используется для чтения данных о событиях из концентратора событий Azure.
Пример данных
Используя пример источника данных (события желтого такси или фондового рынка), вы можете легко протестировать конфигурацию без необходимости написания кода, так как примеры данных отправляются непосредственно в поток событий.
Имя источника — понятное имя источника, которое отображается в потоке событий.
Пример данных . Выберите примеры данных "Желтое такси" или "Фондовый рынок".
Custom application (Пользовательское приложение)
Пользовательское приложение обеспечивает конечную точку потоковой передачи, где можно указать существующие центры событий или клиенты Kafka на поток событий в Microsoft Fabric без необходимости вносить изменения в код.
Имя источника — понятное имя источника, которое отображается в потоке событий.