通过Azure Event Hub触发函数处理Azure IoT Hub遥测数据遇阻求助

已配置Azure IoT Hub及模拟设备，IoT Explorer验证设备运行正常，期望通过Event Hub触发函数监控遥测数据，但函数仅能通过Code+Test手动触发，无法自动触发，以下是排查步骤及代码修正建议：

问题代码（存在语法错误） #

public class static ProcessTelemetry{

    [FunctionName("ProcessTelemetry")]
    public static async Task Run([EventHubTrigger("messages/events", Connection = "EventHubDefaultConnection")] EventData[] events, ILogger log)

    {

        var exceptions = new List<Exception>();

        foreach (EventData eventData in events)
        {
            try
            {
                // Replace these two lines with your processing logic.
                log.LogInformation($"C# Event Hub trigger function processed a message: {eventData.EventBody}");
                await Task.Yield();
            }
            catch (Exception e)
            {
                // We need to keep processing the rest of the batch - capture this exception and continue.
                // Also, consider capturing details of the message that failed processing so it can be processed again later.
                exceptions.Add(e);
            }
        }

        // Once processing of the batch is complete, if any messages in the batch failed processing throw an exception so that there is a record of the failure.

        if (exceptions.Count > 1)
            throw new AggregateException(exceptions);

        if (exceptions.Count == 1)
            throw exceptions.Single();
    }
}

核心代码修正 #

代码中类定义存在语法错误，public class static ProcessTelemetry 应为 public static class ProcessTelemetry，错误的语法会导致函数无法正确编译注册，这是自动触发失效的关键原因之一。修正后的类定义：

public static class ProcessTelemetry
{
    // 函数内容保持不变
}

排查步骤 #

• 确认IoT Hub到Event Hub的路由配置

  • 检查IoT Hub的路由规则，确保数据源为「遥测消息」，目标终结点是正确的Event Hub，且路由状态为启用。
  • 验证终结点的连接权限，确保IoT Hub拥有向该Event Hub发送消息的权限。

• 检查Event Hub触发器配置

  • 确认EventHubTrigger的第一个参数：若使用IoT Hub内置的Event Hub兼容端点，参数应为messages/events；若使用独立创建的Event Hub，参数需改为对应Event Hub的名称。
  • 核对函数应用配置项EventHubDefaultConnection的连接字符串：
    • 若使用IoT Hub内置端点，需使用IoT Hub的服务级连接字符串（如iothubowner、service权限）；
    • 若使用独立Event Hub，需使用带Listen权限的共享访问策略连接字符串。
  • 确认Microsoft.Azure.WebJobs.Extensions.EventHubs NuGet包为最新稳定版，避免版本兼容问题。

• 验证Event Hub的消息流入

  • 在Azure Portal查看Event Hub的「传入消息数」指标，确认IoT Hub的遥测消息已流入Event Hub。若没有消息，问题出在IoT Hub路由配置而非函数。
  • 可通过Event Hub内置工具查看队列中的消息，确认消息存在。

• 检查函数应用状态与权限

  • 确认函数应用处于运行状态，未被停止或暂停。
  • 若使用托管身份，需为其分配Event Hub的「数据接收者」角色；若使用连接字符串，确保对应共享访问策略拥有Listen权限。

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