如何在IoTEdge上运行时间触发型Azure Function并部署为模块？

1. 创建带Timer Trigger的Azure Function项目（C#） #

• 用Visual Studio或VS Code创建Azure Function项目，选择Timer Trigger模板，配置CRON表达式（例如0 */5 * * * *表示每5分钟执行一次，注意Azure Functions的CRON为6字段：秒 分 时 日 月 周）。
• 确保项目目标框架匹配IoT Edge runtime支持的版本（推荐.NET 6或.NET 7）。

2. 适配IoT Edge模块环境 #

• 添加IoT Edge通信依赖NuGet包：Microsoft.Azure.Devices.Client，用于和IoT Edge Hub交互发送消息。
• 在Timer Trigger函数中编写更新检查及消息发送逻辑：

  using Microsoft.Azure.Devices.Client;
  using Microsoft.Azure.WebJobs;
  using Microsoft.Extensions.Logging;
  using System.Text;
  using System.Threading.Tasks;
  using Newtonsoft.Json;
  
  namespace UpdateCheckerFunction
  {
      public class UpdateChecker
      {
          private readonly ModuleClient _moduleClient;
  
          public UpdateChecker()
          {
              // 从IoT Edge环境变量自动获取连接信息，初始化ModuleClient
              _moduleClient = ModuleClient.CreateFromEnvironmentAsync(TransportType.Amqp).Result;
          }
  
          [FunctionName("UpdateChecker")]
          public async Task Run([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, ILogger log)
          {
              log.LogInformation($"更新检查任务触发: {DateTime.Now}");
  
              // 执行自定义更新检查逻辑
              bool updateAvailable = CheckForUpdates();
  
              if (updateAvailable)
              {
                  // 构造消息内容
                  var updateMsg = new 
                  { 
                      UpdateDetected = true, 
                      CheckTime = DateTime.UtcNow.ToString("yyyy-MM-ddTHH:mm:ssZ") 
                  };
                  var msgBytes = Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(updateMsg));
                  var outboundMsg = new Message(msgBytes);
  
                  // 发送到指定输出端点（需与路由配置对应）
                  await _moduleClient.SendEventAsync("updateOutput", outboundMsg);
                  log.LogInformation("更新通知消息已发送至IoT Edge路由");
              }
          }
  
          private bool CheckForUpdates()
          {
              // 替换为实际的更新检查逻辑（如对比版本号、检测文件变更等）
              return true;
          }
      }
  }
  

3. 配置Docker与部署清单 #

• Dockerfile配置：参考IoT Edge兼容的.NET镜像构建流程，示例如下：

  # 构建阶段
  FROM mcr.microsoft.com/dotnet/sdk:6.0 AS build-env
  WORKDIR /app
  
  COPY *.csproj ./
  RUN dotnet restore
  
  COPY . ./
  RUN dotnet publish -c Release -o out
  
  # 运行阶段
  FROM mcr.microsoft.com/dotnet/runtime:6.0
  WORKDIR /app
  COPY --from=build-env /app/out .
  
  # IoT Edge模块需设置的环境变量
  ENV AzureWebJobsScriptRoot=/app
  ENV AzureFunctionsJobHost__Logging__Console__IsEnabled=true
  
  ENTRYPOINT ["dotnet", "UpdateCheckerFunction.dll"]
  

• 部署清单配置：在deployment.template.json中添加模块定义及路由规则：

  "modulesContent": {
    "$edgeAgent": {
      "properties.desired": {
        "modules": {
          "UpdateCheckerFunction": {
            "settings": {
              "image": "${MODULES.UpdateCheckerFunction}",
              "createOptions": {}
            },
            "type": "docker",
            "version": "1.0",
            "status": "running",
            "restartPolicy": "always"
          }
        }
      }
    },
    "$edgeHub": {
      "properties.desired": {
        "routes": {
          "updateNotifications": "FROM /messages/modules/UpdateCheckerFunction/outputs/updateOutput INTO BrokeredEndpoint(\"/modules/TargetModule/inputs/updateNotifications\")"
        }
      }
    }
  }
  

4. 构建并部署到IoT Edge #

• 使用Azure IoT Edge CLI或VS Code的IoT Edge工具链，构建模块镜像并推送到私有容器注册表。
• 将生成的部署清单应用到目标IoT Edge设备，完成模块部署。

常见问题排查 #

• Timer Trigger不触发：检查CRON表达式格式是否正确，确保模块容器时间与UTC同步（IoT Edge模块默认使用UTC时间）。
• 消息发送失败：验证ModuleClient初始化是否成功，检查IoT Edge Hub的路由规则中端点名称是否与代码及目标模块输入配置匹配。

内容的提问来源于stack exchange，提问作者Raghav Rawat