了解如何在 IoT Edge 中部署模块和建立路由

项目
06/17/2024

适用于： IoT Edge 1.5 IoT Edge 1.4

重要

IoT Edge 1.5 LTS 和 IoT Edge 1.4 LTS 是受支持的版本。 IoT Edge 1.4 LTS 的生命周期结束日期为 2024 年 11 月 12 日。如果你使用的是较低的版本，请参阅更新 IoT Edge。

每个 IoT Edge 设备至少运行两个模块：$edgeAgent 和 $edgeHub，它们构成了 IoT Edge 运行时。 IoT Edge 设备可以为任意数量的进程运行多个模块。使用部署清单告知设备要安装哪些模块以及如何将它们配置为协同工作。

部署清单是一个 JSON 文档，用于描述以下内容：

IoT Edge 代理模块孪生，其中包含三个组件：
- 在设备上运行的每个模块的容器映像。
- 用于访问包含模块映像的专用容器注册表的凭据。
- 有关如何创建和管理每个模块的说明。
IoT Edge 中心模块孪生：描述消息如何在模块之间流动，并最终传送到 IoT 中心。
任何额外模块孪生的所需属性（可选）。

必须使用部署清单配置所有 IoT Edge 设备。在使用有效清单进行配置前，新安装的 IoT Edge 运行时会报告错误代码。

在 Azure IoT Edge 教程中，你将通过 Azure IoT Edge 门户中的向导生成部署清单。此外，也可以使用 REST 或 IoT 中心服务 SDK 以编程方式应用部署清单。有关详细信息，请参阅了解 IoT Edge 部署。

创建部署清单。

从较高层面讲，部署清单是配置了所需属性的模块孪生的列表。部署清单告知某个 IoT Edge 设备（或一组设备）要安装哪些模块，以及如何配置这些模块。部署清单包含每个模块孪生的所需属性。 IoT Edge 设备将报告每个模块的报告属性。

每个部署清单中需要两个模块：$edgeAgent 和 $edgeHub。这些模块属于管理 IoT Edge 设备及其上运行的模块的 IoT Edge 运行时。有关这些模块的详细信息，请参阅了解 IoT Edge 运行时及其体系结构。

除了两个运行时模块以外，还可以添加最多 50 个你自己的要在 IoT Edge 设备上运行的模块。

仅包含 IoT Edge 运行时（edgeAgent 和 edgeHub）的部署清单是有效的。

部署清单遵循以下结构：

{
  "modulesContent": {
    "$edgeAgent": { // required
      "properties.desired": {
        // desired properties of the IoT Edge agent
        // includes the image URIs of all deployed modules
        // includes container registry credentials
      }
    },
    "$edgeHub": { //required
      "properties.desired": {
        // desired properties of the IoT Edge hub
        // includes the routing information between modules, and to IoT Hub
      }
    },
    "module1": {  // optional
      "properties.desired": {
        // desired properties of module1
      }
    },
    "module2": {  // optional
      "properties.desired": {
        // desired properties of module2
      }
    }
  }
}

配置模块

定义 IoT Edge 运行时如何在部署中安装模块。 IoT Edge 代理是管理 IoT Edge 设备的安装、更新和状态报告的运行时组件。因此，$edgeAgent 模块孪生包含所有模块的配置和管理信息。此信息包括 IoT Edge 代理本身的配置参数。

$edgeAgent 属性遵循此结构：

{
  "modulesContent": {
    "$edgeAgent": {
      "properties.desired": {
        "schemaVersion": "1.1",
        "runtime": {
          "settings":{
            "registryCredentials":{
              // give the IoT Edge agent access to container images that aren't public
            }
          }
        },
        "systemModules": {
          "edgeAgent": {
            // configuration and management details
          },
          "edgeHub": {
            // configuration and management details
          }
        },
        "modules": {
          "module1": {
            // configuration and management details
          },
          "module2": {
            // configuration and management details
          }
        }
      }
    },
    "$edgeHub": { ... },
    "module1": { ... },
    "module2": { ... }
  }
}

IoT Edge 代理架构版本 1.1 随 IoT Edge 版本 1.0.10 一起发布，并启用了模块启动顺序。对于运行版本 1.0.10 或更高版本的 IoT Edge 部署，建议使用架构版本 1.1。

模块配置和管理

在 IoT Edge 代理所需的属性列表中，你定义要将哪些模块部署到 IoT Edge 设备以及如何配置和管理它们。

有关可以或必须包含的所需属性的完整列表，请参阅 IoT Edge 代理和 IoT Edge 中心的属性。

例如：

{
  "modulesContent": {
    "$edgeAgent": {
      "properties.desired": {
        "schemaVersion": "1.1",
        "runtime": { ... },
        "systemModules": {
          "edgeAgent": { ... },
          "edgeHub": { ... }
        },
        "modules": {
          "module1": {
            "version": "1.0",
            "type": "docker",
            "status": "running",
            "restartPolicy": "always",
            "startupOrder": 2,
            "settings": {
              "image": "myacr.azurecr.cn/module1:latest",
              "createOptions": "{}"
            }
          },
          "module2": { ... }
        }
      }
    },
    "$edgeHub": { ... },
    "module1": { ... },
    "module2": { ... }
  }
}

每个模块都具有 settings 属性，其中包含模块 image、容器注册表中容器映像的地址，以及任何用于在启动时配置映像的 createOptions 。若要了解详细信息，请参阅如何配置 IoT Edge 模块的容器创建选项。

EdgeHub 模块和自定义模块还具有三个属性，这些属性告诉 IoT Edge 代理如何管理它们：

状态：首次部署后，模块是应该运行还是停止。必需。
RestartPolicy:如果 IoT Edge 代理停止，则何时以及是否应重新启动该模块。如果该模块在停止时没有出现任何错误，则不会自动启动。有关详细信息，请参阅 Docker 文档 - 自动启动容器。必需。
StartupOrder：已引入 IoT Edge 版本 1.0.10 中。首次部署时，IoT Edge 代理应按哪个顺序启动模块。此顺序是使用整数进行声明的，其中先启动给定启动值为 0 的模块，然后再启动更高值的模块。 EdgeAgent 模块没有启动值，因为它始终先启动。可选。

IoT Edge 代理按启动值的顺序启动模块，但不会等待每个模块完成启动才转到下一个模块。

如果某些模块依赖于其他模块，启动顺序会很有用。例如，你可能希望 edgeHub 模块先启动，以便在其他模块启动时准备好路由消息。或者，你可能想先启动某个存储模块，然后再启动向其发送数据的模块。但是，你应该始终将模块设计为处理其他模块的故障。容器的性质使其可能在任何时间停止并重新启动任何次数。
注意

更改模块的属性会导致该模块重启。例如，如果更改以下各项的属性，则会发生重启：
- 模块映像
- Docker 创建选项
- 环境变量
- 重启策略
- 映像拉取策略
- 版本
- 启动顺序
如果未更改任何模块属性，则模块不会重启。

声明路由

IoT Edge 中心管理模块、IoT 中心和任何下游设备之间的通信。因此，$edgeHub 模块孪生包含名为 routes 的所需属性，该属性声明如何在部署中传递消息。可以在同一个部署中创建多个路由。

使用以下语法在 $edgeHub 所需属性中声明路由：

{
  "modulesContent": {
    "$edgeAgent": { ... },
    "$edgeHub": {
      "properties.desired": {
        "schemaVersion": "1.1",
        "routes": {
          "route1": "FROM <source> WHERE <condition> INTO <sink>",
          "route2": {
            "route": "FROM <source> WHERE <condition> INTO <sink>",
            "priority": 0,
            "timeToLiveSecs": 86400
          }
        },
        "storeAndForwardConfiguration": {
          "timeToLiveSecs": 10
        }
      }
    },
    "module1": { ... },
    "module2": { ... }
  }
}

IoT Edge 中心架构版本 1 随 IoT Edge 版本 1.0.10 一起发布，并启用了路由优先级和生存时间。对于运行版本 1.0.10 或更高版本的 IoT Edge 部署，建议使用架构版本 1.1。

每一个路由都需要一个消息源和一个消息去往的接收器。条件是可用于筛选消息的可选片断。

你可以将优先级分配给要确保优先处理消息的路由。在上游连接较弱或受限且有需要优先于标准遥测消息进行处理的关键数据的情况下，此功能很有用。

源

源指定消息来自何处。 IoT Edge 可以路由来自模块或下游设备的消息。

通过 IoT SDK，模块可以使用 ModuleClient 类为其消息声明特定的输出队列。输出队列不是必需的，但对于管理多个路由很有帮助。下游设备可以使用 IoT SDK 的 DeviceClient 类向 IoT Edge 网关设备发送消息，其方式与向 IoT 中心发送消息的方式相同。有关详细信息，请参阅了解和使用 Azure IoT 中心 SDK。

源属性可采用以下任何值：

源	描述
`/*`	所有设备到云的消息，或者来自任何模块或下游设备的孪生体更改通知
`/twinChangeNotifications`	来自任何模块或下游设备的任何孪生体更改（报告的属性）
`/messages/*`	由模块或下游设备通过某种输出或不通过任何输出发送的任何设备到云的消息
`/messages/modules/*`	由带部分输出或不带输出的模块发送的任何设备到云的消息
`/messages/modules/<moduleId>/*`	由特定模块通过某种输出或不通过任何输出发送的任何设备到云的消息
`/messages/modules/<moduleId>/outputs/*`	由特定模块通过某种输出发送的任何设备到云的消息
`/messages/modules/<moduleId>/outputs/<output>`	由特定模块通过特定输出发送的任何设备到云的消息

条件

条件在路由声明中是可选的。若要将所有消息从源传递到接收器，完全省略 WHERE 子句即可。或者，可以使用 IoT 中心查询语言来筛选满足条件的特定消息或消息类型。 IoT Edge 路由不支持基于孪生标记或属性筛选消息。

在 IoT Edge 中的模块之间传递的消息与在设备和 Azure IoT 中心之间传递的消息的格式是一样的。所有消息都是 JSON 格式的，并具备 systemProperties、appProperties 和 body 参数。

可使用以下语法围绕三个参数中的任何一个生成查询：

系统属性：$<propertyName> 或 {$<propertyName>}
应用程序属性：<propertyName>
正文属性：$body.<propertyName>

请参考设备到云消息路由查询表达式，查看针对消息属性创建查询的示例。

有一个 IoT Edge 特定的示例，即筛选从下游设备到达网关设备的消息的情况。从模块发送的消息包含名为 connectionModuleId 的系统属性。因此，若要将消息从下游设备直接路由到 IoT 中心，请使用以下路由来排除模块消息：

FROM /messages/* WHERE NOT IS_DEFINED($connectionModuleId) INTO $upstream

接收器

接收器定义消息发送到的位置。只有模块和 IoT 中心可以接收消息。无法将消息路由到其他设备。接收器属性中没有通配符选项。

接收器属性可采用以下任何值：

接收器	说明
`$upstream`	将消息发送到 IoT 中心
`BrokeredEndpoint("/modules/<moduleId>/inputs/<input>")`	将消息发送到特定模块的特定输入

IoT Edge 提供至少一次保证。 IoT Edge 中心在本地存储消息，以防路由无法将消息传送到其接收器。例如，如果 IoT Edge 中心无法连接到 IoT 中心，或者目标模块未连接。

IoT Edge 中心会一直存储消息，直到达到在 storeAndForwardConfiguration.timeToLiveSecs的 storeAndForwardConfiguration.timeToLiveSecs 属性中指定的时间。

优先级和生存时间

可以使用仅定义路由的字符串或使用路由字符串、优先级整数和生存时间整数的对象声明路由。

选项 1：

"route1": "FROM <source> WHERE <condition> INTO <sink>",

带有 IoT Edge 中心架构版本 1.1 的 IoT Edge 版本 1.0.10 中引入的选项 2：

"route2": {
  "route": "FROM <source> WHERE <condition> INTO <sink>",
  "priority": 0,
  "timeToLiveSecs": 86400
}

优先级值可以是 0-9，其中 0 是最高优先级。消息的排队基于其终结点。在处理任何针对特定终结点的优先级 1 消息之前，会先处理针对同一终结点的所有优先级 0 消息。如果同一终结点的多个路由具有相同优先级，则会以先到先得的方式处理它们的消息。如果未指定优先级，则将路由分配给最低优先级。

除非显式设置，否则 timeToLiveSecs 属性将从 IoT Edge 中心的 storeAndForwardConfiguration 继承其值。该值可以是任何正整数。

有关如何管理优先级队列的详细信息，请参阅参考页面以了解路由优先级和生存时间。

定义或更新所需属性

部署清单指定部署到 IoT Edge 设备的每个模块的所需属性。部署清单中的所需属性会覆盖模块孪生中当前存在的任何所需属性。

如果未在部署清单中指定模块孪生的所需属性，则 IoT 中心不会以任何方式修改模块孪生。可以编程方式设置所需属性。

将使用用来修改设备孪生的相同机制来修改模块孪生。有关详细信息，请参阅模块孪生开发人员指南。

部署清单示例

以下示例演示了有效部署清单文档的外观。

{
  "modulesContent": {
    "$edgeAgent": {
      "properties.desired": {
        "schemaVersion": "1.1",
        "runtime": {
          "type": "docker",
          "settings": {
            "minDockerVersion": "v1.25",
            "loggingOptions": "",
            "registryCredentials": {
              "ContosoRegistry": {
                "username": "myacr",
                "password": "<password>",
                "address": "myacr.azurecr.cn"
              }
            }
          }
        },
        "systemModules": {
          "edgeAgent": {
            "type": "docker",
            "settings": {
              "image": "mcr.microsoft.com/azureiotedge-agent:1.5",
              "createOptions": "{}"
            }
          },
          "edgeHub": {
            "type": "docker",
            "status": "running",
            "restartPolicy": "always",
            "startupOrder": 0,
            "settings": {
              "image": "mcr.microsoft.com/azureiotedge-hub:1.5",
              "createOptions": "{\"HostConfig\":{\"PortBindings\":{\"443/tcp\":[{\"HostPort\":\"443\"}],\"5671/tcp\":[{\"HostPort\":\"5671\"}],\"8883/tcp\":[{\"HostPort\":\"8883\"}]}}}"
            }
          }
        },
        "modules": {
          "SimulatedTemperatureSensor": {
            "version": "1.5",
            "type": "docker",
            "status": "running",
            "restartPolicy": "always",
            "startupOrder": 2,
            "settings": {
              "image": "mcr.microsoft.com/azureiotedge-simulated-temperature-sensor:1.5",
              "createOptions": "{}"
            }
          },
          "filtermodule": {
            "version": "1.0",
            "type": "docker",
            "status": "running",
            "restartPolicy": "always",
            "startupOrder": 1,
            "env": {
              "tempLimit": {"value": "100"}
            },
            "settings": {
              "image": "myacr.azurecr.cn/filtermodule:latest",
              "createOptions": "{}"
            }
          }
        }
      }
    },
    "$edgeHub": {
      "properties.desired": {
        "schemaVersion": "1.1",
        "routes": {
          "sensorToFilter": {
            "route": "FROM /messages/modules/SimulatedTemperatureSensor/outputs/temperatureOutput INTO BrokeredEndpoint(\"/modules/filtermodule/inputs/input1\")",
            "priority": 0,
            "timeToLiveSecs": 1800
          },
          "filterToIoTHub": {
            "route": "FROM /messages/modules/filtermodule/outputs/output1 INTO $upstream",
            "priority": 1,
            "timeToLiveSecs": 1800
          }
        },
        "storeAndForwardConfiguration": {
          "timeToLiveSecs": 100
        }
      }
    }
  }
}

后续步骤

有关在 $edgeAgent 和 $edgeHub 中可以或必须包含的属性的完整列表，请参阅 IoT Edge 代理和 IoT Edge 中心的属性。
至此，你已了解如何使用 IoT Edge 模块，接下来请继续了解开发 IoT Edge 模块的要求和工具。

通过