Добавление пользовательского источника конечной точки в поток событий

Необходимые компоненты

• Доступ к рабочей области Fabric premium с разрешениями участника или более высокого уровня.

Добавление пользовательских данных конечной точки в качестве источника

Выполните следующие действия, чтобы добавить пользовательский источник конечной точки:

1. Чтобы создать новый поток событий, выберите Eventstream на начальном экране. Убедитесь, что включен параметр расширенных возможностей (предварительная версия ).

   

2. Чтобы добавить пользовательский источник конечной точки, на странице начала работы выберите "Использовать пользовательскую конечную точку".

   

   Или, если у вас уже есть опубликованный поток событий и вы хотите добавить пользовательские данные конечной точки в качестве источника, переключитесь в режим редактирования . Затем выберите " Добавить источник " на ленте и выберите пользовательскую конечную точку.

   

3. На экране пользовательской конечной точки введите имя настраиваемого источника в поле "Имя источника", а затем нажмите кнопку "Добавить".

   

4. После создания пользовательского источника конечной точки вы увидите, что он добавлен в поток событий на холсте в режиме редактирования. Чтобы реализовать эти недавно добавленные пользовательские исходные данные приложения, выберите " Опубликовать".

   

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

Получение строка подключения и пример кода

В области сведений о динамическом представлении можно увидеть три категории: "Базовый", "Ключи" и "Пример кода". Вы также можете выбрать три вкладки протокола: концентратор событий, AMQP и Kafka. Ключи и примеры сведений о коде зависят от протокола.

Базовый показывает имя, описание, тип и состояние пользовательской конечной точки.

Ключи отображаются строка подключения для пользовательской конечной точки, которую можно скопировать и вставить в приложение.

Строка подключения — это строка, совместимая с концентратором событий, которую можно использовать в приложении для получения событий из этого потока событий. Формат концентратора событий — это формат по умолчанию для строка подключения и совместим с пакетом SDK Центры событий Azure. Этот формат можно использовать для подключения к потокам событий с помощью протокола Центров событий.

В следующем примере показано, как выглядит строка подключения в формате концентратора событий:

Endpoint=sb://eventstream-xxxx.servicebus.windows.net/; SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxx;EntityPath=es_xxxxxxxx

Пример кода показывает пример кода , к который можно ссылаться или копировать и вставлять в приложение, отправлять или извлекать данные события в этот поток событий или из нее.

Кроме концентратора событий, другие две вкладки формата протокола, которые можно выбрать в области сведений, являются AMQP и Kafka.

• Формат AMQP совместим с протоколом AMQP 1.0, стандартным протоколом обмена сообщениями, поддерживающим взаимодействие между различными платформами и языками. Этот формат можно использовать для подключения к потокам событий с помощью протокола AMQP.

• Формат Kafka совместим с протоколом Apache Kafka, популярной распределенной потоковой платформой, которая поддерживает обработку данных с высокой пропускной способностью и низкой задержкой. Этот формат можно использовать для подключения к потокам событий с помощью протокола Kafka.

Вы можете выбрать формат протокола, соответствующий потребностям и предпочтениям приложения. Выберите эти вкладки в области сведений , чтобы получить настраиваемые ключи и пример кода. Скопируйте и вставьте строка подключения из раздела "Ключи" в приложение. См. или скопируйте и вставьте предоставленный пример кода для отправки или получения событий с помощью различных протоколов.

Связанное содержимое

Сведения о добавлении других источников в поток событий см. в следующих статьях:

• Потоки данных 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 с разрешениями участника или выше, где находится ваш поток событий.

Добавление настраиваемого приложения в качестве источника

Если вы хотите подключить собственное приложение к потоку событий, можно добавить пользовательский источник приложения. Затем отправьте данные в поток событий с собственным приложением с конечной точкой подключения, предоставляемой в пользовательском приложении. Выполните следующие действия, чтобы добавить пользовательский источник приложения:

1. Выберите новый источник на ленте или "+" на холсте основного редактора, а затем настраиваемое приложение.

2. Введите имя источника для настраиваемого приложения и нажмите кнопку "Добавить".

   

3. После успешного создания пользовательского источника приложения можно переключиться и просмотреть следующие сведения на вкладке "Сведения " на нижней панели:

   

   • Базовый: отображает имя, описание, тип и состояние пользовательского приложения.
   • Ключи: отображает строка подключения для пользовательского приложения, которое можно скопировать и вставить в приложение.
   • Пример кода: показан пример кода, к которому можно ссылаться или скопировать данные события в этот поток событий или извлечь данные события из этого потока событий.

   Для каждой вкладки (пример кода базовых / ключей / ) можно также переключить три вкладки протокола: Eventhub, AMQP и Kafka для доступа к различным форматам протоколов:

   Строка подключения — это концентратор событий, совместимый с строка подключения, и его можно использовать в приложении для получения событий из потока событий. Строка подключения имеет несколько форматов протокола, которые можно переключить и выбрать на вкладке "Ключи". В следующем примере показано, как выглядит строка подключения в формате Центров событий:

   Endpoint=sb://eventstream-xxxxxxxx.servicebus.windows.net/;SharedAccessKeyName=key_xxxxxxxx;SharedAccessKey=xxxxxxxx;EntityPath=es_xxxxxxxx

   Формат концентратора событий — это формат по умолчанию для строка подключения, который совместим с пакетом SDK Центры событий Azure. Этот формат можно использовать для подключения к потоку событий с помощью протокола Центров событий.

   

   Остальные два формата протокола : AMQP и Kafka, которые можно выбрать, щелкнув соответствующие вкладки на вкладке "Ключи".

   Формат AMQP совместим с протоколом AMQP 1.0, который является стандартным протоколом обмена сообщениями, поддерживающим взаимодействие между различными платформами и языками. Этот формат можно использовать для подключения к потоку событий с помощью протокола AMQP.

   Формат Kafka совместим с протоколом Apache Kafka, который является популярной распределенной потоковой платформой, которая поддерживает обработку данных с высокой пропускной способностью и низкой задержкой. Этот формат можно использовать для подключения к потоку событий с помощью протокола Kafka.

   Вы можете выбрать формат протокола, соответствующий вашим потребностям и предпочтениям приложения, и скопировать и вставить строка подключения в приложение. Вы также можете ссылаться на пример кода или скопировать его на вкладке "Пример кода", в которой показано, как отправлять или получать события с помощью разных протоколов.

Связанное содержимое

Сведения о добавлении других источников в поток событий см. в следующих статьях:

• Центры событий Azure
• Центр Интернета вещей Azure
• Пример данных