te')); return $arr; } /* 遍历用户所有主题 * @param $uid 用户ID * @param int $page 页数 * @param int $pagesize 每页记录条数 * @param bool $desc 排序方式 TRUE降序 FALSE升序 * @param string $key 返回的数组用那一列的值作为 key * @param array $col 查询哪些列 */ function thread_tid_find_by_uid($uid, $page = 1, $pagesize = 1000, $desc = TRUE, $key = 'tid', $col = array()) { if (empty($uid)) return array(); $orderby = TRUE == $desc ? -1 : 1; $arr = thread_tid__find($cond = array('uid' => $uid), array('tid' => $orderby), $page, $pagesize, $key, $col); return $arr; } // 遍历栏目下tid 支持数组 $fid = array(1,2,3) function thread_tid_find_by_fid($fid, $page = 1, $pagesize = 1000, $desc = TRUE) { if (empty($fid)) return array(); $orderby = TRUE == $desc ? -1 : 1; $arr = thread_tid__find($cond = array('fid' => $fid), array('tid' => $orderby), $page, $pagesize, 'tid', array('tid', 'verify_date')); return $arr; } function thread_tid_delete($tid) { if (empty($tid)) return FALSE; $r = thread_tid__delete(array('tid' => $tid)); return $r; } function thread_tid_count() { $n = thread_tid__count(); return $n; } // 统计用户主题数 大数量下严谨使用非主键统计 function thread_uid_count($uid) { $n = thread_tid__count(array('uid' => $uid)); return $n; } // 统计栏目主题数 大数量下严谨使用非主键统计 function thread_fid_count($fid) { $n = thread_tid__count(array('fid' => $fid)); return $n; } ?>open telemetry - How to collect only one metric - Stack Overflow
最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

open telemetry - How to collect only one metric - Stack Overflow

programmeradmin4浏览0评论

New to Opentelemetry and Prometheus.

In the following code, I get 20 point showing up in grafana explore, do you know why?

I was expecting only one as I am only calling "counter.Add(ctx, 1)" once and I am using NewManualReader.

Is the reason that all measurements are "time series" of values?

func GenManuel(ctx context.Context) {
    otlpExporter, err := otlpmetricgrpc.New(ctx,
        otlpmetricgrpc.WithEndpoint("localhost:4317"),
        otlpmetricgrpc.WithInsecure(),
    )
    if err != nil {
        log.Fatalf("Failed to create OTLP exporter: %v", err)
    }
    defer func() {
        if err := otlpExporter.Shutdown(ctx); err != nil {
            log.Fatalf("Failed to flush exporter: %v", err)
        }
    }()

    manualReader := sdkmetric.NewManualReader(
        sdkmetric.WithTemporalitySelector(sdkmetric.DefaultTemporalitySelector),
    )

    res, err := resource.New(ctx,
        resource.WithAttributes(
            semconv.ServiceNameKey.String("example-service"),
        ),
    )
    if err != nil {
        log.Fatalf("Failed to create resource: %v", err)
    }

    meterProvider := sdkmetric.NewMeterProvider(
        sdkmetric.WithReader(manualReader),
        sdkmetric.WithResource(res),
    )
    defer func() {
        if err := meterProvider.Shutdown(ctx); err != nil {
            log.Fatalf("Failed to shutdown MeterProvider: %v", err)
        }
    }()

    meter := meterProvider.Meter("example-service")
    counter, _ := meter.Int64Counter("example_counter")

    counter.Add(ctx, 1)

    time.Sleep(500 * time.Millisecond)

    collectOnce.Do(func() {
        var resourceMetrics metricdata.ResourceMetrics
        err = manualReader.Collect(ctx, &resourceMetrics)
        if err != nil {
            log.Fatalf("Failed to collect metrics: %v", err)
        }

        err = otlpExporter.Export(ctx, &resourceMetrics)
        if err != nil {
            log.Fatalf("Failed to export metrics: %v", err)
        }

        log.Println("Successfully sent metrics to OpenTelemetry Collector once!")
    })
}
发布评论

评论列表(0)

  1. 暂无评论