Добавление пользовательской конечной точки или пользовательского источника приложения в поток событий
Если вы хотите подключить собственное приложение к потоку событий, можно добавить пользовательскую конечную точку или пользовательское приложение в качестве источника. Затем вы можете отправлять события в режиме реального времени в поток событий из собственного приложения с конечной точкой подключения, предоставляемой в пользовательской конечной точке или пользовательском приложении. Кроме того, с протоколом Apache Kafka, доступным в качестве варианта для пользовательских конечных точек или пользовательских приложений, можно отправлять события в режиме реального времени с помощью протокола Apache Kafka.
В этой статье показано, как добавить пользовательский источник конечной точки или пользовательский источник приложения в поток событий Microsoft Fabric.
Примечание.
Если вы хотите использовать расширенные возможности, которые находятся в предварительной версии, выберите расширенные возможности в верхней части. В противном случае выберите стандартные возможности. Сведения о расширенных возможностях, которые находятся в предварительной версии, см. в разделе "Общие сведения о потоках событий Fabric".
Необходимые компоненты
Перед началом работы необходимо получить доступ к рабочей области Fabric premium с разрешениями участника или более высокого уровня.
Примечание.
Максимальное количество источников и назначений для одного потока событий — 11.
Добавление пользовательских данных конечной точки в качестве источника
Создайте новый поток событий:
На домашней странице выберите Eventstream.
В диалоговом окне "Создать поток событий" введите имя, убедитесь, что выбран параметр расширенных возможностей (предварительная версия), а затем нажмите кнопку "Создать".
Чтобы добавить пользовательский источник конечной точки, на странице начала работы выберите "Использовать пользовательскую конечную точку".
Или, если у вас уже есть опубликованный поток событий, и вы хотите добавить пользовательские данные конечной точки в качестве источника, переключитесь в режим редактирования. На ленте выберите "Добавить исходную>пользовательскую конечную точку".
В диалоговом окне "Настраиваемая конечная точка" введите имя настраиваемого источника в поле "Имя источника", а затем нажмите кнопку "Добавить".
После создания пользовательского источника конечной точки он добавляется в поток событий на холсте в режиме редактирования. Чтобы реализовать только что добавленные данные из пользовательского источника приложения, выберите "Опубликовать".
Получение сведений о конечной точке на панели сведений для отправки событий
После создания пользовательского источника конечной точки его данные доступны для визуализации в динамическом представлении.
В области сведений есть три вкладки протокола: Концентратор событий, AMQP и Kafka. Каждая вкладка протокола содержит три страницы: основные сведения, ключи и пример кода. Эти страницы предоставляют сведения о конечной точке с соответствующим протоколом для подключения.
Базовый показывает имя, тип и состояние пользовательской конечной точки.
Ключи содержат сведения о ключах подключения. Пример кода предоставляет пример кода со встроенными ключами, которые можно использовать для потоковой передачи событий в поток событий. Информация на этих страницах зависит от протокола.
концентратор событий;
Страница "Ключи" на вкладке "Концентратор событий" содержит сведения, связанные с строка подключения концентратора событий. Сведения включают имя концентратора событий, имя ключа общего доступа, первичный ключ и первичный ключ подключения.
Формат концентратора событий — это формат по умолчанию для строка подключения, который работает с пакетом SDK Центры событий Azure. Этот формат позволяет подключаться к потоку событий через протокол Центров событий.
В следующем примере показано, как выглядит строка подключения в формате концентратора событий:
Endpoint=sb://eventstream-xxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxx;EntityPath=es_xxxxxxx
На вкладке "Пример кода " на вкладке "Концентратор событий" предоставляется готовый код, содержащий необходимые сведения о ключах подключения в концентраторе событий. Просто скопируйте и вставьте его в приложение для использования.
Kafka
Формат Kafka совместим с протоколом Apache Kafka, который является популярной распределенной потоковой платформой, которая поддерживает обработку данных с высокой пропускной способностью и низкой задержкой. Ключи и примеры кода можно использовать для формата протокола Kafka для подключения к потоку событий и потоковой передачи событий.
Пример кодовой страницы на вкладке Kafka предоставляет готовый код, включая необходимые ключи подключения в формате Kafka. Просто скопируйте его для использования.
AMQP
Формат AMQP совместим с протоколом AMQP 1.0, который является стандартным протоколом обмена сообщениями, поддерживающим взаимодействие между различными платформами и языками. Этот формат можно использовать для подключения к потоку событий с помощью протокола AMQP.
Пример кодовой страницы на вкладке AMQP предоставляет готовый код с информацией ключа подключения в формате AMQP.
Вы можете выбрать формат протокола, соответствующий вашим потребностям и предпочтениям приложения, а затем скопировать и вставить строка подключения в приложение. Вы также можете ссылаться на пример кода или скопировать его на кодовую страницу примера , в которой показано, как отправлять или получать события с помощью различных протоколов.
Связанный контент
Сведения о добавлении других источников в поток событий см. в следующих статьях:
- Потоки данных Amazon Kinesis
- события Хранилище BLOB-объектов Azure
- Azure Cosmos DB
- Центры событий Azure
- Центр Интернета вещей Azure
- База данных SQL Azure отслеживания измененных данных (CDC)
- Confluent Kafka
- Событие рабочей области Fabric
- Google Cloud Pub/Sub
- My База данных SQL CDC
- Postgre База данных SQL CDC
- Пример данных
Необходимые компоненты
Перед началом работы необходимо получить доступ к рабочей области premium с разрешениями участника или более высокого уровня, где находится ваш поток событий.
Примечание.
Максимальное количество источников и назначений для одного потока событий — 11.
Добавление настраиваемого приложения в качестве источника
Если вы хотите подключить собственное приложение к потоку событий, можно добавить пользовательский источник приложения. Затем отправьте данные в поток событий из собственного приложения с конечной точкой подключения, предоставляемой в пользовательском приложении.
Чтобы добавить пользовательский источник приложения, выполните приведенные действия.
Выберите новый источник на ленте или знак плюса (+) на холсте основного редактора и выберите "Пользовательское приложение".
В области "Пользовательское приложение" введите исходное имя настраиваемого приложения и нажмите кнопку "Добавить".
Получение сведений о конечной точке на панели сведений для отправки событий
После успешного создания настраиваемого приложения в качестве источника можно просмотреть сведения на панели сведений .
В области сведений есть три вкладки протокола: Концентратор событий, AMQP и Kafka. Каждая вкладка протокола содержит три страницы: основные сведения, ключи и пример кода. Эти страницы предоставляют сведения о конечной точке с соответствующим протоколом для подключения.
В разделе "Базовый" отображается имя, тип и состояние пользовательского приложения.
Ключи содержат сведения о ключах подключения. Пример кода предоставляет пример кода со встроенными ключами, которые можно использовать для потоковой передачи событий в поток событий. Информация на этих страницах зависит от протокола.
концентратор событий;
Страница "Ключи" на вкладке "Концентратор событий" содержит сведения, связанные с строка подключения концентратора событий. Сведения включают имя концентратора событий, имя ключа общего доступа, первичный ключ и первичный ключ подключения.
Формат концентратора событий — это формат по умолчанию для строка подключения, который работает с пакетом SDK Центры событий Azure. Этот формат позволяет подключаться к потоку событий через протокол Центров событий.
В следующем примере показано, как выглядит строка подключения в формате концентратора событий:
Endpoint=sb://eventstream-xxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxx;EntityPath=es_xxxxxxx
На вкладке "Пример кода " на вкладке "Концентратор событий" предоставляется готовый код, содержащий необходимые сведения о ключах подключения в концентраторе событий. Просто скопируйте и вставьте его в приложение для использования.
Kafka
Формат Kafka совместим с протоколом Apache Kafka, который является популярной распределенной потоковой платформой, которая поддерживает обработку данных с высокой пропускной способностью и низкой задержкой. Ключи и примеры кода можно использовать для формата протокола Kafka для подключения к потоку событий и потоковой передачи событий.
Пример кодовой страницы на вкладке Kafka предоставляет готовый код, включая необходимые ключи подключения в формате Kafka. Просто скопируйте его для использования.
AMQP
Формат AMQP совместим с протоколом AMQP 1.0, который является стандартным протоколом обмена сообщениями, поддерживающим взаимодействие между различными платформами и языками. Этот формат можно использовать для подключения к потоку событий с помощью протокола AMQP.
Пример кодовой страницы на вкладке AMQP предоставляет готовый код с информацией ключа подключения в формате AMQP.
Вы можете выбрать формат протокола, соответствующий вашим потребностям и предпочтениям приложения, а затем скопировать и вставить строка подключения в приложение. Вы также можете ссылаться на пример кода или скопировать его на кодовую страницу примера , в которой показано, как отправлять или получать события с помощью различных протоколов.
Связанный контент
Сведения о добавлении других источников в поток событий см. в следующих статьях: