你当前正在访问 Microsoft Azure Global Edition 技术文档网站。如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

为 SSE 配置连接器

在 Azure IoT 操作中，服务器发送事件的连接器（SSE）允许访问 HTTP 服务公开的 SSE 终结点中的数据。

Azure IoT 操作中的资产是用于表示物理资产或设备的逻辑实体。 Azure IoT 操作资产可以具有描述其行为和特征的自定义属性、数据点、流和事件。资产与一个或多个设备相关联。 Azure IoT 操作将资产定义存储在 Azure 设备注册表中。

Azure IoT 操作中的设备是一个逻辑实体，用于定义与物理资产或设备的连接。如果没有设备，数据无法从物理设备或资产流向 MQTT 代理。配置设备和资产时，将建立与物理资产或设备的连接，而数据点值、事件和流将到达 Azure IoT 操作实例。设备具有一个或多个入站终结点。 Azure IoT 操作将设备定义存储在 Azure 设备注册表中。

SSE 的连接器支持以下功能：

发生采样失败时自动重试。报告无法重试的错误的失败状态。
与 OpenTelemetry 集成。
使用 设备终结点 和资产。
从 JSON 数据载荷推断架构。
多种身份验证方法：
- 用户名/密码基本 HTTP 身份验证
- x509 客户端证书
- 证书信任列表
- 用于测试目的的匿名访问

对于每个配置的数据集，SSE 的连接器：

从指定的 SSE 终结点采样 SSE 事件。
根据接收的数据为每个数据集生成消息架构，并将其注册到架构注册表和 Azure 设备注册表。
将事件数据转发到指定的目标。

本文介绍如何使用 SSE 的连接器执行如下任务：

定义将 SSE 源连接到 Azure IoT 操作实例的设备。
添加资产，并定义事件以启用从 SSE 源到 MQTT 中转站或中转站状态存储的数据流。

先决条件

若要配置设备和资产，需要运行 Azure IoT 操作实例。

要登录到操作体验 Web UI，则需要至少具有包含 Kubernetes - Azure Arc 实例的资源组参与者权限的 Microsoft Entra ID 帐户。无法使用 Microsoft 帐户 (MSA) 登录。有关详细信息，请参阅排查对操作 Web UI 界面的访问问题。

IT 管理员必须在 Azure 门户中为你的 Azure IoT 操作实例配置 SSE 模板的连接器。

需要任何凭据才能访问 SSE 源。如果 SSE 源需要身份验证，则需要创建包含 SSE 源用户名和密码的 Kubernetes 机密。

为 SSE 部署连接器

当您部署 Azure IoT 操作时，部署包括各种连接器。在操作体验 Web UI 中使用连接器（例如 ONVIF、媒体和 HTTP/REST）之前，管理员必须将连接器模板实例添加到 Azure IoT 操作实例。

所有连接器都可以将捕获的数据发布到 MQTT 中转站。

若要将连接器模板实例添加到 Azure IoT 操作实例，请执行以下操作：

在 Azure 门户中，转到 Azure IoT 操作实例，选择“连接器模板”，然后选择“添加连接器模板实例”：
在 “添加 Akri 连接器模板 向导”的第一页上，选择要添加的连接器模板的类型和版本，例如 ONVIF、媒体、 HTTP/REST、 SSE 或 MQTT。然后选择“元数据”。
在“元数据”页上，接受默认值，然后选择“设备入站终结点类型”。
在“设备入站终结点类型”页上，接受默认值，然后选择“诊断配置”。
在“诊断配置”页上，接受默认值，然后选择“运行时配置”。
在 “运行时配置 ”页上，接受默认值，然后选择“ 审阅”。
在“审阅”页上，查看连接器模板实例的详细信息，然后选择“创建”以创建连接器模板实例。

OT 用户现在可以使用操作体验 Web UI 来创建具有连接器终结点的设备。

创建设备

若要配置 SSE 的连接器，请先创建一个定义与 SSE 源的连接的设备。设备包括 SSE 源的 URL 以及访问 SSE 源所需的任何凭据：

在操作体验 Web UI 中，选择左侧导航窗格中的“设备”。然后选择“新建”。
输入设备的名称，例如 sse-connector。若要为 SSE 的连接器添加终结点，请在 Microsoft.SSEHttp 磁贴上选择“新建”。
添加 SSE 连接器终结点的详细信息，包括任何身份验证凭据：

选择“应用”以保存终结点。
在“设备详细信息”页上，选择“下一步”以继续。
在 “添加自定义属性 ”页上，添加要与设备关联的任何其他属性。例如，可以添加一个属性来指示相机制造商。然后选择“下一步”继续。
在“摘要”页上，查看设备的详细信息，然后选择“创建”以创建资产。
创建设备后，可以在“设备”列表中查看它：

运行以下命令：

az iot ops ns device create -n sse-connector-cli -g {your resource group name} --instance {your instance name} 

az iot ops ns device endpoint inbound add sse --device sse-connector-cli -g {your resource group name} -i {your instance name}  --name sse-connector-0 --endpoint-address "https://sse-connector-0:443/base-path"

要了解详细信息，请参阅 az iot ops ns device。

部署以下 Bicep 模板，为 SSE 连接器创建具有入站终结点的设备。分别将占位符 <AIO_NAMESPACE_NAME> 和 <CUSTOM_LOCATION_NAME> 替换为 Azure IoT 操作命名空间名称和自定义位置名称：

param aioNamespaceName string = '<AIO_NAMESPACE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'

resource namespace 'Microsoft.DeviceRegistry/namespaces@2025-10-01' existing = {
  name: aioNamespaceName
}

resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}

resource device 'Microsoft.DeviceRegistry/namespaces/devices@2025-10-01' = {
  name: 'sse-connector'
  parent: namespace
  location: resourceGroup().location
  extendedLocation: {
    type: 'CustomLocation'
    name: customLocation.id
  }
  properties: {
    endpoints: {
      outbound: {
        assigned: {}
      }
      inbound: {
        'sse-connector-0': {
          endpointType: 'Microsoft.SSEHttp'
          address: 'https://sse-connector-0:443/base-path'
        }
      }
    }
  }
}

将设备配置为使用用户名和密码

上述示例使用了 Anonymous 身份验证模式。此模式不需要用户名或密码。

若要使用 Username password 身份验证模式，请完成以下步骤：

按照 “管理 Azure IoT作部署的机密 ”中的步骤，在 Azure Key Vault 中添加用户名和密码的机密，将其投影到 Kubernetes 群集中，并从设备配置中引用它们。

按照 Azure IoT作部署的“管理机密 ”中的步骤，在 Azure Key Vault 中添加用户名和密码的机密，并将其投影到 Kubernetes 群集中。

修改连接器的 Bicep 配置块来引用用户名和密码的这些同步秘密，如以下示例所示：

authentication: {
    method: 'UsernamePassword'
        usernamePasswordCredentials: {
            passwordSecretName: '<reference to synced password secret>'
            usernameSecretName: '<reference to synced username secret>'
        }
}

将设备配置为使用 X.509 证书

若要使用 X509 certificate 身份验证模式，请按照管理用于外部通信的证书的步骤在 Azure Key Vault 中添加证书的机密，将其投影到 Kubernetes 群集中，并从设备配置中引用它们。

为设备配置可用的证书信任列表

若要管理 SSE 连接器的受信任证书列表，请参阅管理用于外部通信的证书。

创建资产

若要定义从 SSE 终结点发布事件的资产，请执行以下步骤：

在操作体验 Web UI 中，选择左侧导航窗格中的“资产”。然后选择“ 创建资产”。
选择上个部分创建的 SSE 的连接器的入站终结点。
输入资产的名称，例如 my-sse-source。
添加要与资产关联的任何自定义属性。例如，可以添加一个属性来指示相机制造商。选择“下一步”继续操作。
在 “数据集 ”页上，创建所需的任何数据集并定义数据点。
在 “事件组 ”页上，创建事件组以定义要发布到 MQTT 中转站的事件。
在事件组中，选择“ 添加事件 ”以添加资产的事件。例如：

添加要发布到 MQTT 代理的每个事件的详细信息。

选择“下一步”继续操作。
在“审阅”页上，查看资产的详细信息，然后选择“创建”以创建资产。几分钟后，资产将列在 “资产 ”页上：

运行下面的命令：

az iot ops ns asset sse create --name mysseasset --instance {your instance name} -g {your resource group name} --device sse-connector-cli --endpoint sse-connector-0

az iot ops ns asset sse dataset add --asset mysseasset --instance {your instance name} -g {your resource group name} --name weatherdata --data-source "/api/weather" --dest topic="azure-iot-operations/data/erp" retain=Never qos=Qos1 ttl=3600

若要了解详细信息，请参阅 az iot ops ns asset sse。

部署以下 Bicep 模板，以创建一个资源，用于将前面显示的设备的消息发布到 MQTT 主题。数据集的数据源定义要查询的 REST 终结点上的路径。分别将占位符 <AIO_NAMESPACE_NAME> 和 <CUSTOM_LOCATION_NAME> 替换为 Azure IoT 操作命名空间名称和自定义位置名称：

param aioNamespaceName string = '<AIO_NAMESPACE_NAME>'
param customLocationName string = '<CUSTOM_LOCATION_NAME>'

resource namespace 'Microsoft.DeviceRegistry/namespaces@2025-10-01' existing = {
  name: aioNamespaceName
}

resource customLocation 'Microsoft.ExtendedLocation/customLocations@2021-08-31-preview' existing = {
  name: customLocationName
}

resource asset 'Microsoft.DeviceRegistry/namespaces/assets@2025-10-01' = {
  name: 'mysseasset'
  parent: namespace
  location: resourceGroup().location
  extendedLocation: {
    type: 'CustomLocation'
    name: customLocation.id
  }
  properties: {
    displayName: 'mysseasset'
    description: 'An example SSE asset'
    enabled: true

    deviceRef: {
      deviceName: 'sse-connector'
      endpointName: 'sse-connector-0'
    }

    defaultDatasetsConfiguration: '{}'
    defaultEventsConfiguration: '{}'

    datasets: [
      {
        name: 'weatherdata'
        dataSource: '/api/weather'
        destinations: [
          {
            target: 'Mqtt'
            configuration: {
              topic: 'azure-iot-operations/data/erp'
              qos: 'Qos1'
              retain: 'Never'
              ttl: 3600
            }
          }
        ]
      }
    ]
  }
}

反馈

此页面是否有帮助？

Last updated on 2025-12-11