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

如果要将自己的应用程序与事件流连接,可以添加自定义终结点(即标准功能的自定义应用)源。 然后,使用显示为自定义终结点(即标准功能的自定义应用)的连接终结点,从自己的应用程序发送数据到事件流。 本文演示如何将自定义终结点(即标准功能的自定义应用)源添加到事件流。

注意

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

先决条件

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

重要

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

注意

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

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

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

  1. 若要创建新的事件流,请从主屏幕中选择“事件流”。 确保已启用“增强功能(预览版)”选项。

    创建新事件流的屏幕截图。

  2. 要添加自定义终结点源,请在“入门”页面上,选择“使用自定义终结点”

    选择“使用自定义终结点”的屏幕截图。

    或者,如果已有已发布的事件流,并且想要将自定义终结点数据添加为源,请切换到“编辑”模式。 然后在功能区中选择“添加源”,然后选择“自定义终结点”

    选择要添加到现有事件流的自定义终结点的屏幕截图。

  3. “自定义终结点”屏幕上,在“源名称”下,输入自定义源的名称,然后选择“添加”

    显示“自定义终结点”屏幕的屏幕截图,其中突出显示了“添加”按钮。

  4. 创建自定义终结点源后,会看到其在“编辑模式”下添加到画布上的事件流。 若要实现新添加的自定义应用源数据,请选择“发布”

    显示“编辑模式”下事件流的屏幕截图,其中突出显示了“发布”按钮。

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

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

获取连接字符串和示例代码

在实时视图的“详细信息”窗格中,可以看到三个类别:“基本”、“密钥”和“示例代码”。 还可以从三个协议选项卡中进行选择:“事件中心”AMQPKafka。 “密钥”和“示例代码”信息因协议而异。

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

显示事件流实时视图“详细信息”窗格中“基本”信息的屏幕截图。

密钥:显示自定义终结点的连接字符串,可将其复制粘贴到应用程序中。

显示事件流实时视图“详细信息”窗格中“密钥信息”的屏幕截图。

连接字符串是与事件中心兼容的字符串,可以在应用程序中使用它接收来自事件流的事件。 “事件中心”格式是连接字符串的默认格式,与 Azure 事件中心 SDK 兼容。 可以使用此格式通过事件中心协议连接到事件流。

以下示例显示了“事件中心”格式的连接字符串的呈现效果:

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

“示例代码”显示了可以引用或复制并粘贴到应用程序中的示例代码,以便向此事件流推送或从此事件流拉取事件数据。

显示事件流实时视图“详细信息”窗格中“示例代码”的屏幕截图。

除了“事件中心”,可以在“详细信息”窗格中选择的其他两个协议格式选项卡是 AMQPKafka

  • AMQP 格式与 AMQP 1.0 协议兼容,后者是一种标准消息传递协议,支持不同平台和语言之间的互操作性。 可以使用此格式通过 AMQP 协议连接到事件流。

  • Kafka 格式与 Apache Kafka 协议兼容,后者是一种流行的分布式流式处理平台,支持高吞吐量和低延迟的数据处理。 可以使用此格式通过 Kafka 协议连接到事件流。

可以选择符合应用程序需求和首选项的协议格式。 在“详细信息”窗格中选择这些选项卡以获取自定义的“密钥”和“示例代码”。 将“密钥”部分中的连接字符串复制并粘贴到应用程序中。 请参阅或复制并粘贴提供的示例代码,以使用不同的协议发送或接收事件。

若要了解如何将其他源添加到 eventstream,请参阅以下文章:

先决条件

开始之前,你必须满足以下先决条件:

  • 获取访问具有参与者或更高级别权限的高级工作区的权限,你的事件流放置在此工作区中。

注意

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

添加自定义应用作为源

如果要将自己的应用程序与事件流连接,可以添加自定义应用源。 然后,使用在自定义应用中公开的连接终结点,通过自己的应用程序将数据发送到事件流。 按照以下步骤添加自定义应用源:

  1. 在功能区上选择“新建源”或在主编辑器画布中选择“+”,然后选择“自定义应用”。

  2. 输入自定义应用的源名称,然后选择“添加”。

    显示自定义应用源配置的屏幕截图。

  3. 成功创建自定义应用程序源后,可以在下方窗格的“详细信息”选项卡中切换并查看以下信息:

    显示自定义应用源的屏幕截图。

    • 基本信息:显示自定义应用的名称、说明、类型和状态。
    • 密钥:显示自定义应用程序的连接字符串,可将其复制粘贴到应用程序中。
    • 示例代码:显示示例代码,可以参考或复制该代码,将事件数据推送到此事件流或从此事件流中拉取事件数据。

    对于每个选项卡(“基本信息” / “密钥” / “示例代码”),还可以切换三个协议选项卡:EventhubAMQPKafka,用于访问不同协议格式信息

    连接字符串是与事件中心兼容的连接字符串,可以在应用程序中使用它来接收来自事件流的事件。 连接字符串有多种协议格式,可以在“密钥”选项卡中进行切换和选择。以下示例显示了事件中心格式的连接字符串的呈现效果:

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

    事件中心”格式是连接字符串的默认格式,与 Azure 事件中心 SDK 兼容。 可以使用此格式通过事件中心协议连接到事件流。

    屏幕截图显示自定义应用详细信息。

    另外两种协议格式是 AMQP 和 Kafka,可以通过点击“密钥”选项卡中的相应选项卡进行选择

    AMQP 格式与 AMQP 1.0 协议兼容,后者是一种标准消息传递协议,支持不同平台和语言之间的互操作性。 可以使用此格式通过 AMQP 协议连接到事件流。

    Kafka 格式与 Apache Kafka 协议兼容,后者是一种流行的分布式流式处理平台,支持高吞吐量和低延迟的数据处理。 可以使用此格式通过 Kafka 协议连接到事件流。

    可以选择适合应用程序需求和偏好的协议格式,将连接字符串复制并粘贴到应用程序中。 还可以参考或复制“示例代码”选项卡中提供的示例代码,其中显示了如何使用不同协议发送或接收事件。

若要了解如何将其他源添加到 eventstream,请参阅以下文章: