如何通过Azure定时触发函数以设备身份向IoT Hub发送消息？

我原本通过模拟设备每30秒向IoT Hub发送遥测数据，本地生成的.exe运行正常，但运行程序的电脑偶尔会关机，于是尝试将功能迁移至Azure定时触发函数。虽然日志显示正常，但消息并未实际发送到IoT Hub。想请教：是否可以通过Azure函数以设备身份发送消息？

相关代码如下：

设备客户端初始化代码 #

s_deviceClient = DeviceClient.Create(s_iotHubUri, new DeviceAuthenticationWithRegistrySymmetricKey(s_myDeviceId, s_deviceKey), TransportType.Mqtt);

using var cts = new CancellationTokenSource();
var messages = SendDeviceToCloudMessagesAsync(cts.Token);
await s_deviceClient.CloseAsync(cts.Token);
await messages;
cts.Cancel();

发送消息函数代码 #

string combinedString = fileStrings[0] + fileStrings[1];
var telemetryDataString = converter.SerializeObject(combinedString);

using var message = new Message(Encoding.UTF8.GetBytes(telemetryDataString))
    {
     ContentEncoding = "utf-8",
     ContentType = "application/json",
    };

await s_deviceClient.SendEventAsync(message);
await Task.Delay(interval);

完全可以通过Azure函数以设备身份向IoT Hub发送消息，你的问题大概率出在代码逻辑或资源释放时机上，以下是关键修复点和正确实现思路：

1. 修复原有代码的资源释放问题 #

你原代码里在启动发送任务后立刻调用await s_deviceClient.CloseAsync(cts.Token);，这会直接关闭设备客户端连接，导致后续的SendEventAsync无法正常发送消息。正确顺序应该是先等待发送任务完成，再关闭客户端：

using var cts = new CancellationTokenSource();
try
{
    var messages = SendDeviceToCloudMessagesAsync(cts.Token);
    await messages;
}
finally
{
    await s_deviceClient.CloseAsync(cts.Token);
    cts.Cancel();
}

2. Azure定时函数中的正确实现方式 #

在Azure定时触发函数中，无需长时间保持连接，每次触发时创建客户端、发送消息、关闭连接即可，避免连接泄漏：

public static async Task Run([TimerTrigger("*/30 * * * * *")]TimerInfo myTimer, ILogger log)
{
    string s_iotHubUri = "你的IoT Hub URI";
    string s_myDeviceId = "你的设备ID";
    string s_deviceKey = "你的设备密钥";
    
    using var deviceClient = DeviceClient.Create(s_iotHubUri, new DeviceAuthenticationWithRegistrySymmetricKey(s_myDeviceId, s_deviceKey), TransportType.Mqtt);
    
    // 替换为你的数据构造逻辑
    string combinedString = fileStrings[0] + fileStrings[1];
    var converter = new JavaScriptSerializer();
    var telemetryDataString = converter.SerializeObject(combinedString);
    
    using var message = new Message(Encoding.UTF8.GetBytes(telemetryDataString))
    {
        ContentEncoding = "utf-8",
        ContentType = "application/json",
    };
    
    await deviceClient.SendEventAsync(message);
    log.LogInformation("遥测消息已发送至IoT Hub");
}

3. 排查要点 #

• 确认Azure函数应用服务计划的网络配置：若IoT Hub设置了IP防火墙，需将函数的出站IP加入允许列表，或启用VNet集成
• 验证设备信息：确保设备密钥正确、设备已在IoT Hub注册且状态正常
• 启用IoT Hub日志诊断：查看是否有消息被拒绝的记录，比如格式错误、认证失败等

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