Azure Function持续重复发送相同指标值，如何实现单次请求发送一次？

问题描述 #

我希望通过Azure Function向Azure Application Insights发送指标数据，当前代码实现如下，但发起一次请求后，指标会持续重复上报直到停止函数，即便没有新请求。请问这是否正常？如何实现每次请求仅发送一次指标？

现有代码 #

指标上报工具函数 #

from opencensus.ext.azure import metrics_exporter
from opencensus.stats import aggregation as aggregation_module
from opencensus.stats import measure as measure_module
from opencensus.stats import stats as stats_module
from opencensus.stats import view as view_module
from opencensus.tags import tag_map as tag_map_module
import os  # 补充原代码缺失的os导入

def build_sum_aggregation_metric(measure_name, measure_description, measure_unit, view_name, view_description, metric_value):   
    stats = stats_module.stats
    view_manager = stats.view_manager
    stats_recorder = stats.stats_recorder

    MEASURE = measure_module.MeasureInt(measure_name,
                                                measure_description,
                                                measure_unit)

    VIEW = view_module.View(view_name,
                                    view_description,
                                    [],
                                    MEASURE,
                                    aggregation_module.SumAggregation())

    instrumentation_key = os.getenv("APP_INSIGHTS_KEY")
    exporter = metrics_exporter.new_metrics_exporter(
            connection_string=instrumentation_key
        )
    view_manager.register_exporter(exporter)

    view_manager.register_view(VIEW)


    mmap = stats_recorder.new_measurement_map()
    tmap = tag_map_module.TagMap()

    mmap.measure_int_put(MEASURE, metric_value)
    mmap.record(tmap)

Azure Function主函数 #

import azure.functions as func
import json

def main(req: func.HttpRequest) -> func.HttpResponse:
    req_body = req.get_json()
    build_sum_aggregation_metric("metric 1","metric 1","metric 1", "metric 1", "metric 1", 5)
        
    build_sum_aggregation_metric("metric 2","metric 2","metric 2", "metric 2", "metric 2", 10)
    response ={ "value" : "metric sent" }

    return func.HttpResponse(
        json.dumps(response),
        headers={
            "Content-Type": "application/json"
        }
    )

重复上报原因 #

这不是正常行为，核心问题在于：

• 每次调用build_sum_aggregation_metric时，都会重新创建Metrics Exporter并注册到View Manager，且旧的Exporter不会被销毁
• OpenCensus Exporter默认周期性批量上报（默认15秒间隔），每个存活的Exporter都会持续上报已记录的指标数据
• 重复注册同名View会导致View Manager中存在多个相同视图，进一步加剧重复上报

解决方案：全局初始化复用资源 #

将Exporter和View的初始化逻辑移到全局作用域，仅在函数实例启动时执行一次，避免每次请求重复创建。

重构后代码示例 #

全局初始化部分（仅执行一次）

from opencensus.ext.azure import metrics_exporter
from opencensus.stats import aggregation as aggregation_module
from opencensus.stats import measure as measure_module
from opencensus.stats import stats as stats_module
from opencensus.stats import view as view_module
from opencensus.tags import tag_map as tag_map_module
import os
import azure.functions as func
import json

# 全局统计实例，复用整个实例生命周期
stats = stats_module.stats
view_manager = stats.view_manager
stats_recorder = stats.stats_recorder

# 预定义指标的Measure和View（按需扩展）
METRIC_1_MEASURE = measure_module.MeasureInt("metric_1", "metric 1描述", "count")
METRIC_1_VIEW = view_module.View(
    "metric_1_view", 
    "metric 1视图描述", 
    [], 
    METRIC_1_MEASURE, 
    aggregation_module.SumAggregation()
)

METRIC_2_MEASURE = measure_module.MeasureInt("metric_2", "metric 2描述", "count")
METRIC_2_VIEW = view_module.View(
    "metric_2_view", 
    "metric 2视图描述", 
    [], 
    METRIC_2_MEASURE, 
    aggregation_module.SumAggregation()
)

# 初始化Exporter并注册所有View
instrumentation_key = os.getenv("APP_INSIGHTS_KEY")
exporter = metrics_exporter.new_metrics_exporter(connection_string=instrumentation_key)
view_manager.register_exporter(exporter)
view_manager.register_view(METRIC_1_VIEW)
view_manager.register_view(METRIC_2_VIEW)

def record_metric(measure, value):
    """通用指标记录函数，仅负责写入指标值"""
    mmap = stats_recorder.new_measurement_map()
    tmap = tag_map_module.TagMap()
    mmap.measure_int_put(measure, value)
    mmap.record(tmap)

函数主逻辑

def main(req: func.HttpRequest) -> func.HttpResponse:
    req_body = req.get_json()
    record_metric(METRIC_1_MEASURE, 5)
    record_metric(METRIC_2_MEASURE, 10)
    
    response = {"value": "metric sent"}
    return func.HttpResponse(
        json.dumps(response),
        headers={"Content-Type": "application/json"}
    )

可选优化：单次上报后停止Exporter #

如果需要单次请求后立即终止上报（仅适合一次性任务，不推荐常规函数使用），可在记录指标后手动停止Exporter：

def record_metric(measure, value):
    mmap = stats_recorder.new_measurement_map()
    tmap = tag_map_module.TagMap()
    mmap.measure_int_put(measure, value)
    mmap.record(tmap)
    # 停止Exporter，终止后续批量上报
    exporter.stop()

关键注意事项 #

• Azure Function全局代码在实例启动时仅执行一次，后续请求复用同一实例，避免重复初始化资源
• 避免在请求处理函数中重复注册Exporter和View，这是重复上报的核心诱因
• 若需每次请求上报独立数值而非累计值，可将SumAggregation替换为LastValueAggregation

内容的提问来源于stack exchange，提问作者Yafaa Ben Tili