能否在第二个Azure函数应用中汇总两个函数的服务总线消息处理时间指标？

完全可以在第二个Azure函数应用中实现汇总处理时间并捕获综合指标的需求，具体操作步骤如下：

• 第一步：在1号函数中传递自身处理时间
  1号函数完成消息处理后，计算自身的处理耗时（从触发器触发到准备转发消息的时间差），将这个值存入要转发给2号的Service Bus消息的自定义属性中（比如用ApplicationProperties["Func1ProcessingTimeMs"]），避免污染消息体的业务内容。
  示例代码（C#）：

  // 1号函数中记录开始时间
  var startTime = DateTime.UtcNow;
  // 执行消息处理逻辑...
  // 计算处理耗时
  var processingTime = (DateTime.UtcNow - startTime).TotalMilliseconds;
  // 创建要转发的消息
  var message = new ServiceBusMessage(JsonSerializer.Serialize(processedData))
  {
      ApplicationProperties = { ["Func1ProcessingTimeMs"] = processingTime }
  };
  // 发送到2号的Service Bus主题
  await serviceBusSender.SendMessageAsync(message);
  

• 第二步：在2号函数中汇总计算总处理时间
  2号函数接收到消息后，先从消息的自定义属性中读取1号的处理时间，再计算自身的处理耗时，两者相加得到端到端的总处理时间。
  示例代码（C#）：

  // 2号函数中记录开始时间
  var startTime = DateTime.UtcNow;
  // 读取1号的处理时间，默认值设为0以防缺失
  if (message.ApplicationProperties.TryGetValue("Func1ProcessingTimeMs", out var func1TimeObj) &&
      double.TryParse(func1TimeObj.ToString(), out var func1ProcessingTime))
  {
      // 执行自身的消息处理逻辑...
      // 计算自身处理耗时
      var func2ProcessingTime = (DateTime.UtcNow - startTime).TotalMilliseconds;
      // 汇总总处理时间
      var totalProcessingTime = func1ProcessingTime + func2ProcessingTime;
  }
  

• 第三步：上报综合指标到Azure Monitor
  在2号函数中，使用TelemetryClient将总处理时间作为自定义指标上报。先注入TelemetryClient实例，再调用TrackMetric方法：

  // 注入TelemetryClient
  private readonly TelemetryClient _telemetryClient;
  public MySecondFunction(TelemetryClient telemetryClient)
  {
      _telemetryClient = telemetryClient;
  }
  
  // 在汇总后上报指标
  _telemetryClient.TrackMetric("TotalEndToEndProcessingTimeMs", totalProcessingTime);
  

• Service Bus的ApplicationProperties会完整传递自定义属性，无需额外配置，确保传递过程中数据不丢失。
• 处理属性缺失的异常情况：如果1号函数的消息未携带处理时间，可将总时间设为自身处理时间，或上报一个异常指标用于排查问题。
• 指标上报后，可在Azure Monitor的指标 explorer 中查看这个自定义指标，还能创建可视化仪表盘、设置阈值警报等。

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