配置媒体连接器（预览版）

在 Azure IoT 操作中，使用媒体连接器（预览版）可访问媒体源（如边缘附加相机）中的媒体。

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

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

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

• 定义将媒体源连接到 Azure IoT 操作实例的设备。
• 添加资产，并定义用于从媒体源捕获媒体的流。
• 将映像快照发送到 MQTT 代理。
• 将视频剪辑保存到 Azure 存储。

Prerequisites

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

要登录到操作体验 Web UI，则需要至少具有包含 Kubernetes - Azure Arc 实例的资源组参与者权限的 Microsoft Entra ID 帐户。 无法使用 Microsoft 帐户 (MSA) 登录。 在 Azure 租户中创建合适的 Microsoft Entra ID 帐户：

1. 使用用于部署 Azure IoT 操作的同一租户和用户名登录到 Azure 门户。
2. 在 Azure 门户中，前往“Microsoft Entra ID”部分，选择“用户”“+ 新用户”>“新建用户”>。 新建用户并记下密码，稍后登录时需要此密码。
3. 在 Azure 门户中，前往包含 Kubernetes - Azure Arc 实例的资源组。 在“访问控制 (IAM)”页上，选择“+ 添加”“添加角色分配”>。
4. 在“添加角色分配”页上，选择“特权管理员角色”。 选择“参与者”，然后选择“下一步”。
5. 在“成员”页上，将新用户添加到角色。
6. 选择“查看并分配”以完成新用户的设置。

现在可以使用新的用户帐户登录到 操作体验 Web 界面。

连接到网络并可从 Azure IoT 操作群集访问的相机。 相机必须支持视频流的实时流协议。 还需要相机的用户名和密码来进行身份验证。

媒体源类型

媒体连接器可以连接到各种源，包括：

任务类型

媒体连接器支持以下任务类型：

示例用法

媒体连接器的示例用法包括：

• 从视频流或图像 URL 捕获快照，并将其发布到 MQTT 主题。 MQTT 主题的订阅者可以使用捕获的映像进行进一步处理或分析。

• 将视频流保存到群集上的本地文件系统。 使用 Azure Arc 启用的 Azure 容器存储 提供可靠且容错的解决方案，用于将捕获的视频上传到云进行存储或处理。

• 将实时视频流从相机代理到操作员可以访问的终结点。 出于安全性和性能原因，只有媒体连接器才能直接访问边缘相机。 媒体连接器使用单独的媒体服务器组件将视频流式传输到操作员的终结点。 此媒体服务器可以转码到各种协议，例如 RTSP、RTCP、SRT 和 HLS。 你需要部署自己的媒体服务器来提供这些功能。

部署媒体连接器

部署 Azure IoT 操作的预览版时，部署包括三个预览连接器。 可以通过在 Azure 门户中检查是否为实例启用了预览功能来验证是否具有 Azure IoT 操作的预览实例：

在操作体验 Web UI 中使用预览连接器（ONVIF、媒体和 HTTP/REST）之前，管理员必须将连接器模板实例添加到 Azure IoT 操作实例。

所有三个预览连接器都可以将捕获的数据发布到 MQTT 代理。 媒体连接器还可以将捕获的数据保存到存储。 Azure IoT 操作使用 Azure Arc 启用的 Azure 容器存储将捕获的数据传输到 Azure Blob 存储等云存储目标。 配置连接器模板实例时，请指定用于保存捕获数据的连接器的永久性卷声明和装载路径。 要了解如何创建合适的永久性卷声明，请参阅云引入边缘卷配置。

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

1. 在 Azure 门户中，转到 Azure IoT 操作实例，选择“连接器模板”，然后选择“添加连接器模板实例”：

   

2. 在 “添加 Akri 连接器模板 向导”的第一页上，选择要添加的连接器模板类型，例如 ONVIF、 媒体、 HTTP/REST 或 SSE HTTP。 然后选择“元数据”。

   

3. 在“元数据”页上，接受默认值，然后选择“设备入站终结点类型”。

4. 在“设备入站终结点类型”页上，接受默认值，然后选择“诊断配置”。

5. 在“诊断配置”页上，接受默认值，然后选择“运行时配置”。

6. 在“运行时配置”页上，选择“添加卷声明”并输入之前创建的永久性卷声明的详细信息。 然后选择“审阅”：

   

7. 在“审阅”页上，查看连接器模板实例的详细信息，然后选择“创建”以创建连接器模板实例。

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

使用媒体终结点创建设备

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

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

az iot ops ns device endpoint inbound add media --device media-connector-cli -g {your resource group name} -i {your instance name}  --name media-connector-cli-0 --endpoint-address rtsp://samplecamera:554/stream1

创建用于发布映像快照的资产

定义将映像快照从媒体源发布到 MQTT 代理的命名空间资产：

az iot ops ns asset media create --name mymediaasset --instance {your instance name}  -g {your resource group name} --device media-connector-cli --endpoint media-connector-cli-0 --task-type snapshot-to-mqtt --task-format jpeg --snapshots-per-sec 0.25 --stream-dest topic="azure-iot-operations/data/snapshots" qos=Qos1 retain=Never ttl=60

验证发布的消息

要验证连接器是否发布消息，可以使用 MQTT 客户端订阅主题 azure-iot-operations/data/{asset name}/{stream name}。 如果正确配置了设备和命名空间资产，则订阅此主题时会收到包含 JPEG 图像快照的消息。

以下步骤演示了如何在群集中运行 mosquitto_sub 工具。 要详细了解此工具和替代方法，请参阅 MQTT 工具：

使用 mosquitto_sub 工具验证数据是否流向 MQTT 代理。 在此示例中，你将在 Kubernetes 群集中运行 mosquitto_sub 工具：

1. 运行以下命令来部署包含 mosquitto_pub 和 mosquitto_sub 工具的 Pod，这些工具可用于与群集中的 MQTT 代理交互：

   kubectl apply -f https://raw.githubusercontent.com/Azure-Samples/explore-iot-operations/main/samples/quickstarts/mqtt-client.yaml
   

   以下代码片段显示了已应用的 YAML 文件：

   # Important: do not use in production environments
   # Create a service account
   apiVersion: v1
   kind: ServiceAccount
   metadata:
     name: mqtt-client
     namespace: azure-iot-operations
   ---
   # Creates a pod with mosquitto-clients and mqttui utilities in your cluster
   apiVersion: v1
   kind: Pod
   metadata:
     name: mqtt-client
     # The namespace must match the IoT MQ BrokerListener's namespace
     # Otherwise use the long hostname: aio-broker.azure-iot-operations.svc.cluster.local
     namespace: azure-iot-operations
   spec:
     # Use the "mqtt-client" service account which comes with default deployment
     # Otherwise create it with `kubectl create serviceaccount mqtt-client -n azure-iot-operations`
     serviceAccountName: mqtt-client
     containers:
       # Install mosquitto and mqttui utilities on Alpine linux
     - image: alpine
       name: mqtt-client
       command: ["sh", "-c"]
       args: ["apk add mosquitto-clients mqttui && sleep infinity"]
       resources:
         limits:
           cpu: 500m
           memory: 200Mi
         requests:
           cpu: 100m
           memory: 100Mi
       volumeMounts:
       - name: broker-sat
         mountPath: /var/run/secrets/tokens
       - name: trust-bundle
         mountPath: /var/run/certs
     volumes:
     - name: broker-sat
       projected:
         sources:
         - serviceAccountToken:
             path: broker-sat
             audience: aio-internal # Must match audience in BrokerAuthentication
             expirationSeconds: 86400
     - name: trust-bundle
       configMap:
         name: azure-iot-operations-aio-ca-trust-bundle # Default root CA cert
   

   注意

   此配置是不安全的。 请勿在生产环境中使用此配置。

2. 运行 mqtt-client pod 时，请运行以下命令以在所创建的 Pod 中创建 shell 环境：

   kubectl exec --stdin --tty mqtt-client -n azure-iot-operations -- sh
   

3. 在 Bash shell 的 mqtt-client pod 中，运行以下命令使用 mosquitto_sub 工具连接到 MQTT 代理，并使用通配符订阅 主题data/#：

   mosquitto_sub --host aio-broker --port 18883 --topic "azure-iot-operations/data/#" -v --debug --cafile /var/run/certs/ca.crt -D CONNECT authentication-method 'K8S-SAT' -D CONNECT authentication-data $(cat /var/run/secrets/tokens/broker-sat)
   

   此命令继续运行并在消息到达任何 data/# 主题时显示消息，直到按 Ctrl+C 停止它。 要退出 shell 环境，请键入 exit。

要保存单个消息的有效负载，请使用如下所示的命令：

mosquitto_sub --host aio-broker --port 18883 --topic "azure-iot-operations/data/my-camera/#" -C 1 -F %p --cafile /var/run/certs/
ca.crt -D CONNECT authentication-method 'K8S-SAT' -D CONNECT authentication-data $(cat /var/run/secrets/tokens/broker-sat) > image1.
jpeg

以下屏幕截图显示了使用资产名称和流名称的主题名称：

添加流以保存视频剪辑

在本部分中，向资产添加一个流，用于将视频剪辑从媒体源保存到文件系统。

az iot ops ns asset media stream add --asset mymediaasset --instance {your instance name}  -g {your resource group name} --name clipStream --task-type clip-to-fs --format mp4 --duration 30 --path /data/clips

验证保存的消息

以下步骤假定你配置了永久性卷声明 (PVC)，以便使用以下设置将剪辑保存到 Azure Blob 存储帐户：

连接器捕获剪辑后，它会将它们上传到容器中的 /pvc/clips 文件夹：