将自定义终结点源添加到事件流

项目
10/25/2024

如果要将自己的应用程序与事件流连接，可以添加自定义终结点（即标准功能的自定义应用）源。然后，可以使用自定义终结点上公开的连接终结点（即标准功能的自定义应用）从自己的应用程序将实时事件发送到事件流。此外，使用 Apache Kafka 协议作为自定义终结点（即标准功能的自定义应用）选项，可以使用 Apache Kafka 协议发送实时事件。本文演示如何将自定义终结点（即标准功能的自定义应用）源添加到事件流。

注意

如果要使用预览版中的增强功能，请选择顶部的“增强功能”。否则，请选择“标准功能”。有关预览版中增强功能的信息，请参阅 Fabric 事件流简介。

先决条件

使用“参与者”或更高权限访问 Fabric 高级工作区。

重要

Fabric 事件流的增强功能目前以预览版方式提供。

注意

一个事件流的源和目标的最大数量为 11。

将自定义终结点数据添加为源

按照以下步骤添加自定义终结点源：

若要创建新的事件流，请从主屏幕中选择“事件流”。确保已启用“增强功能（预览版）”选项。
要添加自定义终结点源，请在“入门”页面上，选择“使用自定义终结点”。

或者，如果已有已发布的事件流，并且想要将自定义终结点数据添加为源，请切换到“编辑”模式。然后在功能区中选择“添加源”，然后选择“自定义终结点”。
在“自定义终结点”屏幕上，在“源名称”下，输入自定义源的名称，然后选择“添加”。
创建自定义终结点源后，会看到其在“编辑模式”下添加到画布上的事件流。若要实现新添加的自定义应用源数据，请选择“发布”。

完成这些步骤后，自定义终结点数据可用于“实时视图”中的可视化效果。

显示实时视图中的事件流的屏幕截图。

在“详细信息”窗格中获取终结点详细信息以发送事件

“ 详细信息 ”窗格有三个协议选项卡： 事件中心、 AMQP 和 Kafka。每个协议选项卡有三个页面： 基本信息、密钥和 示例代码 ，其中提供了终结点详细信息以及用于连接的相应协议。

基本：显示自定义终结点的名称、说明、类型和状态。

密钥和 示例代码 页提供连接密钥信息和示例代码，以及嵌入的相应键，可用于将事件流式传输到事件流。 “密钥”和“示例代码”信息因协议而异。

事件中心

事件中心协议格式中的密钥包含与事件中心连接字符串相关的信息，包括事件中心名称、共享访问密钥名称、主密钥和连接字符串-主键。事件中心格式是连接字符串的默认格式，适用于 Azure 事件中心 SDK。此格式允许通过事件中心协议连接到事件流。以下示例显示了“事件中心”格式的连接字符串的呈现效果：

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