Prometheus
package otel;
import io.prometheus.metrics.core.metrics.Counter;
import io.prometheus.metrics.exporter.httpserver.HTTPServer;
import java.io.IOException;
public class PrometheusScrapeInit {
public static void main(String[] args) throws IOException, InterruptedException {
// Створіть лічильник і зареєструйте його в стандартному PrometheusRegistry.
Counter doorOpens =
Counter.builder()
.name("door_opens_total")
.help("Total number of times a door has been opened")
.labelNames("door")
.register();
// Запустіть HTTP-сервер; Prometheus збирає дані з http://localhost:9464/metrics.
HTTPServer server = HTTPServer.builder().port(9464).buildAndStart();
Runtime.getRuntime().addShutdownHook(new Thread(server::close));
doorOpens.labelValues("front").inc();
Thread.currentThread().join(); // очікувати нескінченно
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.LongCounter;
import io.opentelemetry.api.metrics.Meter;
import io.opentelemetry.exporter.prometheus.PrometheusHttpServer;
import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
public class OtelScrapeInit {
// Попередньо виділіть ключі атрибутів і, коли значення статичні, цілі об'єкти Attributes.
private static final AttributeKey<String> DOOR = AttributeKey.stringKey("door");
private static final Attributes FRONT_DOOR = Attributes.of(DOOR, "front");
public static void main(String[] args) throws InterruptedException {
// Налаштуйте SDK: зареєструйте Prometheus reader, який обслуговує /metrics.
OpenTelemetrySdk sdk =
OpenTelemetrySdk.builder()
.setMeterProvider(
SdkMeterProvider.builder()
.registerMetricReader(PrometheusHttpServer.builder().setPort(9464).build())
.build())
.build();
Runtime.getRuntime().addShutdownHook(new Thread(sdk::close));
// Код інструментування використовує тип API OpenTelemetry, а не тип SDK безпосередньо.
OpenTelemetry openTelemetry = sdk;
// Метрики обслуговуються за адресою http://localhost:9464/metrics.
Meter meter = openTelemetry.getMeter("smart.home");
LongCounter doorOpens =
meter
.counterBuilder("door.opens")
.setDescription("Total number of times a door has been opened")
.build();
doorOpens.add(1, FRONT_DOOR);
Thread.currentThread().join(); // очікувати нескінченно
}
}
Prometheus
package main
import (
"net/http"
"github.com/prometheus/client_golang/prometheus"
"github.com/prometheus/client_golang/prometheus/promhttp"
)
func main() {
// Створіть лічильник і зареєструйте його у власному реєстрі.
reg := prometheus.NewRegistry()
doorOpens := prometheus.NewCounterVec(prometheus.CounterOpts{
Name: "door_opens_total",
Help: "Total number of times a door has been opened",
}, []string{"door"})
reg.MustRegister(doorOpens)
// Prometheus зчитує дані з http://localhost:9464/metrics.
http.Handle("/metrics", promhttp.HandlerFor(reg, promhttp.HandlerOpts{}))
go http.ListenAndServe(":9464", nil) //nolint:errcheck
doorOpens.WithLabelValues("front").Inc()
select {} // очікувати нескінченно
}
OpenTelemetry
package main
import (
"context"
"net/http"
"github.com/prometheus/client_golang/prometheus/promhttp"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/exporters/prometheus"
"go.opentelemetry.io/otel/metric"
sdkmetric "go.opentelemetry.io/otel/sdk/metric"
)
func main() {
ctx := context.Background()
// Налаштуйте SDK: зареєструйте Prometheus reader, який обслуговує /metrics.
exporter, err := prometheus.New()
if err != nil {
panic(err)
}
provider := sdkmetric.NewMeterProvider(sdkmetric.WithReader(exporter))
defer provider.Shutdown(ctx) //nolint:errcheck
// Метрики обслуговуються за адресою http://localhost:9464/metrics.
http.Handle("/metrics", promhttp.Handler())
go http.ListenAndServe(":9464", nil) //nolint:errcheck
// Код інструментування використовує тип API OpenTelemetry, а не тип SDK безпосередньо.
meter := provider.Meter("smart.home")
doorOpens, err := meter.Int64Counter("door.opens",
metric.WithDescription("Total number of times a door has been opened"))
if err != nil {
panic(err)
}
doorOpens.Add(ctx, 1, metric.WithAttributes(attribute.String("door", "front")))
select {} // очікувати нескінченно
}
Prometheus
package otel;
import io.prometheus.metrics.core.metrics.Counter;
import io.prometheus.metrics.exporter.opentelemetry.OpenTelemetryExporter;
public class PrometheusOtlpInit {
public static void main(String[] args) throws Exception {
// Створіть лічильник і зареєструйте його у стандартному реєстрі Prometheus.
Counter doorOpens =
Counter.builder()
.name("door_opens_total")
.help("Total number of times a door has been opened")
.labelNames("door")
.register();
// Запустіть експортер OTLP. Він читає дані з стандартного реєстру Prometheus і
// надсилає метрики на налаштовану точку доступу з фіксованим інтервалом.
OpenTelemetryExporter exporter =
OpenTelemetryExporter.builder()
.protocol("http/protobuf")
.endpoint("http://localhost:4318")
.intervalSeconds(60)
.buildAndStart();
Runtime.getRuntime().addShutdownHook(new Thread(exporter::close));
doorOpens.labelValues("front").inc();
Thread.currentThread().join(); // очікувати нескінченно
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.metrics.LongCounter;
import io.opentelemetry.api.metrics.Meter;
import io.opentelemetry.exporter.otlp.http.metrics.OtlpHttpMetricExporter;
import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
import io.opentelemetry.sdk.metrics.export.PeriodicMetricReader;
import java.time.Duration;
public class OtelOtlpInit {
public static void main(String[] args) throws InterruptedException {
// Налаштуйте SDK: експортуйте метрики через OTLP/HTTP з фіксованим інтервалом.
OpenTelemetrySdk sdk =
OpenTelemetrySdk.builder()
.setMeterProvider(
SdkMeterProvider.builder()
.registerMetricReader(
PeriodicMetricReader.builder(
OtlpHttpMetricExporter.builder()
.setEndpoint("http://localhost:4318")
.build())
.setInterval(Duration.ofSeconds(60))
.build())
.build())
.build();
Runtime.getRuntime().addShutdownHook(new Thread(sdk::close));
// Код інструментування використовує тип API OpenTelemetry, а не тип SDK безпосередньо.
OpenTelemetry openTelemetry = sdk;
Meter meter = openTelemetry.getMeter("smart.home");
LongCounter doorOpens =
meter
.counterBuilder("door.opens")
.setDescription("Total number of times a door has been opened")
.build();
doorOpens.add(1);
Thread.currentThread().join(); // очікувати нескінченно
}
}
Prometheus
Клієнтська бібліотека Prometheus для Go не включає експортер OTLP push.
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetrichttp"
"go.opentelemetry.io/otel/metric"
sdkmetric "go.opentelemetry.io/otel/sdk/metric"
)
func main() {
ctx := context.Background()
// Налаштуйте SDK: експортуйте метрики через OTLP/HTTP з фіксованим інтервалом.
// Точка доступу зазвичай localhost:4318 і може бути налаштована через
// змінну середовища OTEL_EXPORTER_OTLP_ENDPOINT.
exporter, err := otlpmetrichttp.New(ctx)
if err != nil {
panic(err)
}
provider := sdkmetric.NewMeterProvider(
sdkmetric.WithReader(sdkmetric.NewPeriodicReader(exporter)),
)
defer provider.Shutdown(ctx) //nolint:errcheck
meter := provider.Meter("smart.home")
doorOpens, err := meter.Int64Counter("door.opens",
metric.WithDescription("Total number of times a door has been opened"))
if err != nil {
panic(err)
}
doorOpens.Add(ctx, 1, metric.WithAttributes(attribute.String("door", "front")))
select {} // очікувати нескінченно
}
Prometheus
package otel;
import io.prometheus.metrics.core.metrics.Counter;
public class PrometheusCounter {
public static void counterUsage() {
Counter hvacOnTime =
Counter.builder()
.name("hvac_on_seconds_total")
.help("Total time the HVAC system has been running, in seconds")
.labelNames("zone")
.register();
// Попередньо привʼязати до наборів значень міток: наступні виклики йдуть безпосередньо до точки даних,
// пропускаючи внутрішній пошук серії.
var upstairs = hvacOnTime.labelValues("upstairs");
var downstairs = hvacOnTime.labelValues("downstairs");
upstairs.inc(127.5);
downstairs.inc(3600.0);
// Попередньо ініціалізувати зони, щоб вони зʼявлялися у /metrics зі значенням 0 при запуску.
hvacOnTime.initLabelValues("basement");
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.DoubleCounter;
import io.opentelemetry.api.metrics.Meter;
public class OtelCounter {
// Попередньо виділити ключі атрибутів і, коли значення статичні, цілі обʼєкти Attributes.
private static final AttributeKey<String> ZONE = AttributeKey.stringKey("zone");
private static final Attributes UPSTAIRS = Attributes.of(ZONE, "upstairs");
private static final Attributes DOWNSTAIRS = Attributes.of(ZONE, "downstairs");
public static void counterUsage(OpenTelemetry openTelemetry) {
Meter meter = openTelemetry.getMeter("smart.home");
// Час роботи системи опалення, вентиляції та кондиціонування (HVAC) виражається у дробовій формі — використовується функція `useOfDoubles()` для отримання лічильника типу `DoubleCounter`.
// Відсутність попереднього оголошення міток: атрибути задаються під час запису.
DoubleCounter hvacOnTime =
meter
.counterBuilder("hvac.on")
.setDescription("Total time the HVAC system has been running")
.setUnit("s")
.ofDoubles()
.build();
hvacOnTime.add(127.5, UPSTAIRS);
hvacOnTime.add(3600.0, DOWNSTAIRS);
}
}
Ключові відмінності:
inc(value) → add(value). На відміну від Prometheus, OpenTelemetry вимагає явного значення — немає скорочення inc().LongCounter (цілі числа, зазвичай) і DoubleCounter (через .ofDoubles(), для дробових значень). Prometheus використовує один тип Counter.AttributeKey (завжди) і обʼєкти Attributes (коли значення статичні), щоб уникнути виділення пам’яті при кожному виклику на гарячому шляху.Prometheus
package main
import "github.com/prometheus/client_golang/prometheus"
var hvacOnTime = prometheus.NewCounterVec(prometheus.CounterOpts{
Name: "hvac_on_seconds_total",
Help: "Total time the HVAC system has been running, in seconds",
}, []string{"zone"})
func prometheusCounterUsage(reg *prometheus.Registry) {
reg.MustRegister(hvacOnTime)
// Попередньо привʼязати до наборів значень міток: наступні виклики йдуть безпосередньо до точки даних,
// пропускаючи внутрішній пошук серії.
upstairs := hvacOnTime.WithLabelValues("upstairs")
downstairs := hvacOnTime.WithLabelValues("downstairs")
upstairs.Add(127.5)
downstairs.Add(3600.0)
// Попередньо ініціалізувати серію, щоб вона зʼявлялася у /metrics зі значенням 0.
hvacOnTime.WithLabelValues("basement")
}
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
)
// Попередньо виділяйте опції атрибутів, коли значення статичні, щоб уникнути виділення пам'яті при кожному виклику.
var (
zoneUpstairsOpts = []metric.AddOption{metric.WithAttributes(attribute.String("zone", "upstairs"))}
zoneDownstairsOpts = []metric.AddOption{metric.WithAttributes(attribute.String("zone", "downstairs"))}
)
func otelCounterUsage(ctx context.Context, meter metric.Meter) {
// Відсутність попереднього оголошення міток: атрибути задаються під час запису.
hvacOnTime, err := meter.Float64Counter("hvac.on",
metric.WithDescription("Total time the HVAC system has been running"),
metric.WithUnit("s"))
if err != nil {
panic(err)
}
hvacOnTime.Add(ctx, 127.5, zoneUpstairsOpts...)
hvacOnTime.Add(ctx, 3600.0, zoneDownstairsOpts...)
}
Ключові відмінності:
Add(value) → Add(ctx, value, metric.WithAttributes(...)). Усі виклики інструментів вимагають context.Context як першого аргументу.meter.Float64Counter і meter.Int64Counter є окремими методами. Prometheus використовує один тип Counter.(Instrument, error) і помилку потрібно обробляти.Prometheus
package otel;
import io.prometheus.metrics.core.metrics.CounterWithCallback;
public class PrometheusCounterCallback {
public static void counterCallbackUsage() {
// Кожна зона має власний розумний лічильник енергії, який відстежує накопичені джоулі.
// Використовуйте лічильник із зворотним викликом, щоб повідомляти ці значення під час збору даних,
// не підтримуючи окремі лічильники в коді програми.
CounterWithCallback.builder()
.name("energy_consumed_joules_total")
.help("Total energy consumed in joules")
.labelNames("zone")
.callback(
callback -> {
callback.call(SmartHomeDevices.totalEnergyJoules("upstairs"), "upstairs");
callback.call(SmartHomeDevices.totalEnergyJoules("downstairs"), "downstairs");
})
.register();
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.Meter;
public class OtelCounterCallback {
private static final AttributeKey<String> ZONE = AttributeKey.stringKey("zone");
private static final Attributes UPSTAIRS = Attributes.of(ZONE, "upstairs");
private static final Attributes DOWNSTAIRS = Attributes.of(ZONE, "downstairs");
public static void counterCallbackUsage(OpenTelemetry openTelemetry) {
Meter meter = openTelemetry.getMeter("smart.home");
// Кожна зона має власний розумний лічильник енергії, який відстежує накопичені джоулі.
// Використовуйте асинхронний лічильник, щоб повідомляти ці значення під час збору даних,
// не підтримуючи окремі лічильники в коді програми.
meter
.counterBuilder("energy.consumed")
.setDescription("Total energy consumed")
.setUnit("J")
.ofDoubles()
.buildWithCallback(
measurement -> {
measurement.record(SmartHomeDevices.totalEnergyJoules("upstairs"), UPSTAIRS);
measurement.record(SmartHomeDevices.totalEnergyJoules("downstairs"), DOWNSTAIRS);
});
}
}
Ключові відмінності:
.ofDoubles() вибирає числовий варіант з рухомою комою. Prometheus CounterWithCallback завжди використовує значення з рухомою комою.Prometheus
package main
import "github.com/prometheus/client_golang/prometheus"
type energyCollector struct{ desc *prometheus.Desc }
func newEnergyCollector() *energyCollector {
return &energyCollector{desc: prometheus.NewDesc(
"energy_consumed_joules_total",
"Total energy consumed in joules",
[]string{"zone"}, nil,
)}
}
func (c *energyCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc }
func (c *energyCollector) Collect(ch chan<- prometheus.Metric) {
ch <- prometheus.MustNewConstMetric(c.desc, prometheus.CounterValue, totalEnergyJoules("upstairs"), "upstairs")
ch <- prometheus.MustNewConstMetric(c.desc, prometheus.CounterValue, totalEnergyJoules("downstairs"), "downstairs")
}
func prometheusCounterCallbackUsage(reg *prometheus.Registry) {
// Кожна зона має власний розумний лічильник енергії, який відстежує накопичені джоулі.
// Реалізуйте prometheus.Collector, щоб повідомляти ці значення під час збору даних.
reg.MustRegister(newEnergyCollector())
}
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
)
var (
zoneUpstairs = attribute.String("zone", "upstairs")
zoneDownstairs = attribute.String("zone", "downstairs")
)
func otelCounterCallbackUsage(meter metric.Meter) {
// Кожна зона має власний розумний лічильник енергії, який відстежує накопичені джоулі.
// Використовуйте спостережуваний лічильник, щоб повідомляти ці значення під час збору даних.
_, err := meter.Float64ObservableCounter("energy.consumed",
metric.WithDescription("Total energy consumed"),
metric.WithUnit("J"),
metric.WithFloat64Callback(func(_ context.Context, o metric.Float64Observer) error {
o.Observe(totalEnergyJoules("upstairs"), metric.WithAttributes(zoneUpstairs))
o.Observe(totalEnergyJoules("downstairs"), metric.WithAttributes(zoneDownstairs))
return nil
}))
if err != nil {
panic(err)
}
}
Ключові відмінності:
prometheus.Collector з методами Describe та Collect для повідомлення значень лічильників з мітками.Float64ObservableCounter та Int64ObservableCounter.Prometheus
package otel;
import io.prometheus.metrics.core.metrics.Gauge;
public class PrometheusGauge {
public static void gaugeUsage() {
Gauge thermostatSetpoint =
Gauge.builder()
.name("thermostat_setpoint_celsius")
.help("Target temperature set on the thermostat")
.labelNames("zone")
.register();
thermostatSetpoint.labelValues("upstairs").set(22.5);
thermostatSetpoint.labelValues("downstairs").set(20.0);
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.DoubleGauge;
import io.opentelemetry.api.metrics.Meter;
public class OtelGauge {
// Попередньо виділіть ключі атрибутів і, коли значення статичні, цілі об'єкти Attributes.
private static final AttributeKey<String> ZONE = AttributeKey.stringKey("zone");
private static final Attributes UPSTAIRS = Attributes.of(ZONE, "upstairs");
private static final Attributes DOWNSTAIRS = Attributes.of(ZONE, "downstairs");
public static void gaugeUsage(OpenTelemetry openTelemetry) {
Meter meter = openTelemetry.getMeter("smart.home");
DoubleGauge thermostatSetpoint =
meter
.gaugeBuilder("thermostat.setpoint")
.setDescription("Target temperature set on the thermostat")
.setUnit("Cel")
.build();
thermostatSetpoint.set(22.5, UPSTAIRS);
thermostatSetpoint.set(20.0, DOWNSTAIRS);
}
}
Ключові відмінності:
set(value) → set(value, attributes). Назва методу залишається тією ж.LongGauge (цілі числа, через .ofLongs()) та DoubleGauge (зазвичай). Prometheus використовує один тип Gauge.AttributeKey (завжди) та обʼєкти Attributes (коли значення статичні), щоб уникнути виділення памʼяті при кожному виклику на гарячому шляху.Prometheus
package main
import "github.com/prometheus/client_golang/prometheus"
var thermostatSetpoint = prometheus.NewGaugeVec(prometheus.GaugeOpts{
Name: "thermostat_setpoint_celsius",
Help: "Target temperature set on the thermostat",
}, []string{"zone"})
func prometheusGaugeUsage(reg *prometheus.Registry) {
reg.MustRegister(thermostatSetpoint)
thermostatSetpoint.WithLabelValues("upstairs").Set(22.5)
thermostatSetpoint.WithLabelValues("downstairs").Set(20.0)
}
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
)
// Попередньо виділіть параметри атрибутів, коли значення статичні, щоб уникнути виділення пам'яті при кожному виклику.
var (
zoneUpstairsGaugeOpts = []metric.RecordOption{metric.WithAttributes(attribute.String("zone", "upstairs"))}
zoneDownstairsGaugeOpts = []metric.RecordOption{metric.WithAttributes(attribute.String("zone", "downstairs"))}
)
func otelGaugeUsage(ctx context.Context, meter metric.Meter) {
thermostatSetpoint, err := meter.Float64Gauge("thermostat.setpoint",
metric.WithDescription("Target temperature set on the thermostat"),
metric.WithUnit("Cel"))
if err != nil {
panic(err)
}
thermostatSetpoint.Record(ctx, 22.5, zoneUpstairsGaugeOpts...)
thermostatSetpoint.Record(ctx, 20.0, zoneDownstairsGaugeOpts...)
}
Ключові відмінності:
Set(value) → Record(ctx, value, metric.WithAttributes(...)).meter.Float64Gauge та meter.Int64Gauge є окремими методами. Prometheus використовує один тип Gauge.Prometheus
package otel;
import io.prometheus.metrics.core.metrics.GaugeWithCallback;
public class PrometheusGaugeCallback {
public static void gaugeCallbackUsage() {
// Датчики температури підтримують власні показання у прошивці.
// Використовуйте gauge зі зворотним викликом, щоб повідомляти ці значення під час збору, не підтримуючи окремий gauge у коді програми.
GaugeWithCallback.builder()
.name("room_temperature_celsius")
.help("Current temperature in the room")
.labelNames("room")
.callback(
callback -> {
callback.call(SmartHomeDevices.livingRoomTemperatureCelsius(), "living_room");
callback.call(SmartHomeDevices.bedroomTemperatureCelsius(), "bedroom");
})
.register();
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.Meter;
public class OtelGaugeCallback {
private static final AttributeKey<String> ROOM = AttributeKey.stringKey("room");
private static final Attributes LIVING_ROOM = Attributes.of(ROOM, "living_room");
private static final Attributes BEDROOM = Attributes.of(ROOM, "bedroom");
public static void gaugeCallbackUsage(OpenTelemetry openTelemetry) {
Meter meter = openTelemetry.getMeter("smart.home");
// Датчики температури підтримують власні показання у прошивці.
// Використовуйте асинхронний gauge, щоб повідомляти ці значення під час збору метрик,
// не підтримуючи окремі gauge у коді програми.
meter
.gaugeBuilder("room.temperature")
.setDescription("Current temperature in the room")
.setUnit("Cel")
.buildWithCallback(
measurement -> {
measurement.record(SmartHomeDevices.livingRoomTemperatureCelsius(), LIVING_ROOM);
measurement.record(SmartHomeDevices.bedroomTemperatureCelsius(), BEDROOM);
});
}
}
Prometheus
package main
import "github.com/prometheus/client_golang/prometheus"
type temperatureCollector struct{ desc *prometheus.Desc }
func newTemperatureCollector() *temperatureCollector {
return &temperatureCollector{desc: prometheus.NewDesc(
"room_temperature_celsius",
"Current temperature in the room",
[]string{"room"}, nil,
)}
}
func (c *temperatureCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc }
func (c *temperatureCollector) Collect(ch chan<- prometheus.Metric) {
ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, livingRoomTemperatureCelsius(), "living_room")
ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, bedroomTemperatureCelsius(), "bedroom")
}
func prometheusGaugeCallbackUsage(reg *prometheus.Registry) {
// Датчики температури підтримують власні показання у прошивці.
// Реалізуйте prometheus.Collector, щоб повідомляти ці значення під час збору.
reg.MustRegister(newTemperatureCollector())
}
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
)
var (
roomLivingRoom = attribute.String("room", "living_room")
roomBedroom = attribute.String("room", "bedroom")
)
func otelGaugeCallbackUsage(meter metric.Meter) {
// Датчики температури підтримують власні показання у прошивці.
// Використовуйте асинхронний gauge, щоб повідомляти ці значення під час збору метрик,
// не підтримуючи окремі gauge у коді програми.
_, err := meter.Float64ObservableGauge("room.temperature",
metric.WithDescription("Current temperature in the room"),
metric.WithUnit("Cel"),
metric.WithFloat64Callback(func(_ context.Context, o metric.Float64Observer) error {
o.Observe(livingRoomTemperatureCelsius(), metric.WithAttributes(roomLivingRoom))
o.Observe(bedroomTemperatureCelsius(), metric.WithAttributes(roomBedroom))
return nil
}))
if err != nil {
panic(err)
}
}
Ключові відмінності:
prometheus.Collector з методами Describe та Collect для повідомлення значень gauge з мітками.Prometheus
package otel;
import io.prometheus.metrics.core.metrics.Gauge;
public class PrometheusUpDownCounter {
public static void upDownCounterUsage() {
// Prometheus використовує Gauge для значень, які можуть збільшуватися або зменшуватися.
Gauge devicesConnected =
Gauge.builder()
.name("devices_connected")
.help("Number of smart home devices currently connected")
.labelNames("device_type")
.register();
// Інкрементуйте, коли пристрій підключається, декрементуйте, коли він відключається.
devicesConnected.labelValues("thermostat").inc();
devicesConnected.labelValues("thermostat").inc();
devicesConnected.labelValues("lock").inc();
devicesConnected.labelValues("lock").dec();
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.LongUpDownCounter;
import io.opentelemetry.api.metrics.Meter;
public class OtelUpDownCounter {
// Попередньо виділіть ключі атрибутів і, коли значення статичні, цілі об'єкти Attributes.
private static final AttributeKey<String> DEVICE_TYPE = AttributeKey.stringKey("device_type");
private static final Attributes THERMOSTAT = Attributes.of(DEVICE_TYPE, "thermostat");
private static final Attributes LOCK = Attributes.of(DEVICE_TYPE, "lock");
public static void upDownCounterUsage(OpenTelemetry openTelemetry) {
Meter meter = openTelemetry.getMeter("smart.home");
LongUpDownCounter devicesConnected =
meter
.upDownCounterBuilder("devices.connected")
.setDescription("Number of smart home devices currently connected")
.build();
// add() приймає як додатні, так і від'ємні значення.
devicesConnected.add(1, THERMOSTAT);
devicesConnected.add(1, THERMOSTAT);
devicesConnected.add(1, LOCK);
devicesConnected.add(-1, LOCK);
}
}
Ключові відмінності:
inc() / dec() → add(1) / add(-1). add() приймає як додатні, так і від’ємні значення.Gauge; тип OpenTelemetry — LongUpDownCounter (або DoubleUpDownCounter через .ofDoubles()).Prometheus
package main
import "github.com/prometheus/client_golang/prometheus"
// Prometheus використовує Gauge для значень, які можуть збільшуватися або зменшуватися.
var devicesConnected = prometheus.NewGaugeVec(prometheus.GaugeOpts{
Name: "devices_connected",
Help: "Number of smart home devices currently connected",
}, []string{"device_type"})
func prometheusUpDownCounterUsage(reg *prometheus.Registry) {
reg.MustRegister(devicesConnected)
// Інкрементуйте, коли пристрій підключається, декрементуйте, коли він відключається.
devicesConnected.WithLabelValues("thermostat").Inc()
devicesConnected.WithLabelValues("thermostat").Inc()
devicesConnected.WithLabelValues("lock").Inc()
devicesConnected.WithLabelValues("lock").Dec()
}
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
)
// Попередньо виділіть ключі атрибутів і, коли значення статичні, цілі об'єкти Attributes.
var (
deviceThermostatAddOpts = []metric.AddOption{metric.WithAttributes(attribute.String("device_type", "thermostat"))}
deviceLockAddOpts = []metric.AddOption{metric.WithAttributes(attribute.String("device_type", "lock"))}
)
func otelUpDownCounterUsage(ctx context.Context, meter metric.Meter) {
devicesConnected, err := meter.Int64UpDownCounter("devices.connected",
metric.WithDescription("Number of smart home devices currently connected"))
if err != nil {
panic(err)
}
// Add() приймає як додатні, так і від'ємні значення.
devicesConnected.Add(ctx, 1, deviceThermostatAddOpts...)
devicesConnected.Add(ctx, 1, deviceThermostatAddOpts...)
devicesConnected.Add(ctx, 1, deviceLockAddOpts...)
devicesConnected.Add(ctx, -1, deviceLockAddOpts...)
}
Ключові відмінності:
Inc() / Dec() → Add(ctx, 1, ...) / Add(ctx, -1, ...). Add() приймає як додатні, так і від’ємні значення.Gauge; тип OpenTelemetry — Int64UpDownCounter (або Float64UpDownCounter через meter.Float64UpDownCounter).Prometheus
package otel;
import io.prometheus.metrics.core.metrics.GaugeWithCallback;
public class PrometheusUpDownCounterCallback {
public static void upDownCounterCallbackUsage() {
// Менеджер пристроїв підтримує кількість підключених пристроїв.
// Використовуйте gauge зі зворотним викликом, щоб повідомляти це значення під час збору метрик.
GaugeWithCallback.builder()
.name("devices_connected")
.help("Number of smart home devices currently connected")
.labelNames("device_type")
.callback(
callback -> {
callback.call(SmartHomeDevices.connectedDeviceCount("thermostat"), "thermostat");
callback.call(SmartHomeDevices.connectedDeviceCount("lock"), "lock");
})
.register();
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.Meter;
public class OtelUpDownCounterCallback {
private static final AttributeKey<String> DEVICE_TYPE = AttributeKey.stringKey("device_type");
private static final Attributes THERMOSTAT = Attributes.of(DEVICE_TYPE, "thermostat");
private static final Attributes LOCK = Attributes.of(DEVICE_TYPE, "lock");
public static void upDownCounterCallbackUsage(OpenTelemetry openTelemetry) {
Meter meter = openTelemetry.getMeter("smart.home");
// Менеджер пристроїв підтримує кількість підключених пристроїв.
// Використовуйте асинхронний лічильник з можливістю збільшення та зменшення, щоб повідомляти це значення під час збору метрик.
meter
.upDownCounterBuilder("devices.connected")
.setDescription("Number of smart home devices currently connected")
.buildWithCallback(
measurement -> {
measurement.record(SmartHomeDevices.connectedDeviceCount("thermostat"), THERMOSTAT);
measurement.record(SmartHomeDevices.connectedDeviceCount("lock"), LOCK);
});
}
}
Prometheus
package main
import "github.com/prometheus/client_golang/prometheus"
type deviceCountCollector struct{ desc *prometheus.Desc }
func newDeviceCountCollector() *deviceCountCollector {
return &deviceCountCollector{desc: prometheus.NewDesc(
"devices_connected",
"Number of smart home devices currently connected",
[]string{"device_type"}, nil,
)}
}
func (c *deviceCountCollector) Describe(ch chan<- *prometheus.Desc) { ch <- c.desc }
func (c *deviceCountCollector) Collect(ch chan<- prometheus.Metric) {
ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(connectedDeviceCount("thermostat")), "thermostat")
ch <- prometheus.MustNewConstMetric(c.desc, prometheus.GaugeValue, float64(connectedDeviceCount("lock")), "lock")
}
func prometheusUpDownCounterCallbackUsage(reg *prometheus.Registry) {
// Менеджер пристроїв підтримує кількість підключених пристроїв.
// Реалізуйте prometheus.Collector, щоб повідомляти ці значення під час збору метрик.
reg.MustRegister(newDeviceCountCollector())
}
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
)
var (
deviceThermostat = attribute.String("device_type", "thermostat")
deviceLock = attribute.String("device_type", "lock")
)
func otelUpDownCounterCallbackUsage(meter metric.Meter) {
// Менеджер пристроїв підтримує кількість підключених пристроїв.
// Використовуйте асинхронний лічильник з можливістю збільшення та зменшення, щоб повідомляти це значення під час збору метрик.
_, err := meter.Int64ObservableUpDownCounter("devices.connected",
metric.WithDescription("Number of smart home devices currently connected"),
metric.WithInt64Callback(func(_ context.Context, o metric.Int64Observer) error {
o.Observe(int64(connectedDeviceCount("thermostat")), metric.WithAttributes(deviceThermostat))
o.Observe(int64(connectedDeviceCount("lock")), metric.WithAttributes(deviceLock))
return nil
}))
if err != nil {
panic(err)
}
}
Ключові відмінності:
prometheus.Collector з методами Describe та Collect для повідомлення значень gauge з мітками.Int64ObservableUpDownCounter використовує metric.WithInt64Callback.Prometheus
package otel;
import io.prometheus.metrics.core.metrics.Histogram;
public class PrometheusHistogram {
public static void histogramUsage() {
Histogram deviceCommandDuration =
Histogram.builder()
.name("device_command_duration_seconds")
.help("Time to receive acknowledgment from a smart home device")
.labelNames("device_type")
.classicUpperBounds(0.1, 0.25, 0.5, 1.0, 2.5, 5.0)
.register();
deviceCommandDuration.labelValues("thermostat").observe(0.35);
deviceCommandDuration.labelValues("lock").observe(0.85);
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.DoubleHistogram;
import io.opentelemetry.api.metrics.Meter;
import java.util.List;
public class OtelHistogram {
// Попередньо виділяйте ключі атрибутів і, коли значення статичні, цілі об'єкти Attributes.
private static final AttributeKey<String> DEVICE_TYPE = AttributeKey.stringKey("device_type");
private static final Attributes THERMOSTAT = Attributes.of(DEVICE_TYPE, "thermostat");
private static final Attributes LOCK = Attributes.of(DEVICE_TYPE, "lock");
public static void histogramUsage(OpenTelemetry openTelemetry) {
Meter meter = openTelemetry.getMeter("smart.home");
// setExplicitBucketBoundariesAdvice() встановлює стандартні межі як підказку для SDK.
// Види, налаштовані на рівні SDK, мають пріоритет над цією підказкою.
DoubleHistogram deviceCommandDuration =
meter
.histogramBuilder("device.command.duration")
.setDescription("Time to receive acknowledgment from a smart home device")
.setUnit("s")
.setExplicitBucketBoundariesAdvice(List.of(0.1, 0.25, 0.5, 1.0, 2.5, 5.0))
.build();
deviceCommandDuration.record(0.35, THERMOSTAT);
deviceCommandDuration.record(0.85, LOCK);
}
}
Ключові відмінності:
observe(value) → record(value, attributes).LongHistogram (цілі числа, через .ofLongs()) та DoubleHistogram (за замовчуванням). Prometheus використовує один тип Histogram.AttributeKey (завжди) та обʼєкти Attributes (коли значення статичні), щоб уникнути виділення памʼяті при кожному виклику на гарячому шляху.setExplicitBucketBoundariesAdvice(), а також можуть налаштовувати інші аспекти збору гістограм, такі як фільтрація атрибутів, мінімальне/максимальне записування та перейменування інструментів.Prometheus
package main
import "github.com/prometheus/client_golang/prometheus"
var deviceCommandDuration = prometheus.NewHistogramVec(prometheus.HistogramOpts{
Name: "device_command_duration_seconds",
Help: "Time to receive acknowledgment from a smart home device",
Buckets: []float64{0.1, 0.25, 0.5, 1.0, 2.5, 5.0},
}, []string{"device_type"})
func prometheusHistogramUsage(reg *prometheus.Registry) {
reg.MustRegister(deviceCommandDuration)
deviceCommandDuration.WithLabelValues("thermostat").Observe(0.35)
deviceCommandDuration.WithLabelValues("lock").Observe(0.85)
}
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
)
// Попередньо виділяйте опції атрибутів, коли значення статичні, щоб уникнути виділення пам'яті при кожному виклику.
var (
deviceThermostatOpts = []metric.RecordOption{metric.WithAttributes(attribute.String("device_type", "thermostat"))}
deviceLockOpts = []metric.RecordOption{metric.WithAttributes(attribute.String("device_type", "lock"))}
)
func otelHistogramUsage(ctx context.Context, meter metric.Meter) {
// WithExplicitBucketBoundaries встановлює стандартні межі як підказку для SDK.
// Види, налаштовані на рівні SDK, мають пріоритет над цією підказкою.
deviceCommandDuration, err := meter.Float64Histogram("device.command.duration",
metric.WithDescription("Time to receive acknowledgment from a smart home device"),
metric.WithUnit("s"),
metric.WithExplicitBucketBoundaries(0.1, 0.25, 0.5, 1.0, 2.5, 5.0))
if err != nil {
panic(err)
}
deviceCommandDuration.Record(ctx, 0.35, deviceThermostatOpts...)
deviceCommandDuration.Record(ctx, 0.85, deviceLockOpts...)
}
Ключові відмінності:
Observe(value) → Record(ctx, value, metric.WithAttributes(...)).WithExplicitBucketBoundaries(), а також можуть налаштовувати інші аспекти збору гістограм, такі як фільтрація атрибутів, мінімальне/максимальне записування та перейменування інструментів.Prometheus
В Prometheus, формат гістограми контролюється під час створення інструменту. Приклад нижче використовує .nativeOnly(), щоб обмежити формат лише нативним; якщо його опустити, будуть одночасно генеруватись як класичний, так і нативний формати:
package otel;
import io.prometheus.metrics.core.metrics.Histogram;
public class PrometheusHistogramNative {
public static void nativeHistogramUsage() {
Histogram deviceCommandDuration =
Histogram.builder()
.name("device_command_duration_seconds")
.help("Time to receive acknowledgment from a smart home device")
.labelNames("device_type")
.nativeOnly()
.register();
deviceCommandDuration.labelValues("thermostat").observe(0.35);
deviceCommandDuration.labelValues("lock").observe(0.85);
}
}
Prometheus
В Prometheus, встановлення NativeHistogramBucketFactor дозволяє використовувати нативні гістограми разом із класичною конфігурацією кошиків — обидва формати звітуються одночасно:
package main
import "github.com/prometheus/client_golang/prometheus"
var nativeDeviceCommandDuration = prometheus.NewHistogramVec(prometheus.HistogramOpts{
Name: "device_command_duration_seconds",
Help: "Time to receive acknowledgment from a smart home device",
NativeHistogramBucketFactor: 1.1,
}, []string{"device_type"})
func nativeHistogramUsage(reg *prometheus.Registry) {
reg.MustRegister(nativeDeviceCommandDuration)
nativeDeviceCommandDuration.WithLabelValues("thermostat").Observe(0.35)
nativeDeviceCommandDuration.WithLabelValues("lock").Observe(0.85)
}
Ключові відмінності:
NativeHistogramBucketFactor має бути встановлено на значення більше 1.0, щоб увімкнути нативні гістограми в Go — це не є опціональним. Встановлення його на 0 (нульове значення) повністю вимикає нативні гістограми. Значення контролює максимальне співвідношення між послідовними межами кошиків; менші значення дають більш точне розділення за рахунок більшої кількості кошиків. Щоб наблизити ту ж щільність кошиків, що й зазвичай використовуване значення 1.1, встановіть MaxScale: 3 на AggregationBase2ExponentialHistogram.package otel;
import io.opentelemetry.exporter.otlp.http.metrics.OtlpHttpMetricExporter;
import io.opentelemetry.sdk.metrics.Aggregation;
import io.opentelemetry.sdk.metrics.InstrumentType;
import io.opentelemetry.sdk.metrics.export.DefaultAggregationSelector;
public class OtelHistogramExponentialExporter {
static OtlpHttpMetricExporter createExporter() {
// Налаштуйте експортер для використання експоненціальних гістограм для всіх інструментів гістограм.
// Це бажаний підхід — він застосовується глобально без зміни коду інструментування.
return OtlpHttpMetricExporter.builder()
.setEndpoint("http://localhost:4318")
.setDefaultAggregationSelector(
DefaultAggregationSelector.getDefault()
.with(InstrumentType.HISTOGRAM, Aggregation.base2ExponentialBucketHistogram()))
.build();
}
}
package main
import (
"context"
"go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetrichttp"
sdkmetric "go.opentelemetry.io/otel/sdk/metric"
)
func createExponentialExporter(ctx context.Context) (*otlpmetrichttp.Exporter, error) {
// Налаштуйте експортер для використання експоненціальних гістограм для всіх інструментів гістограм.
// Це бажаний підхід — він застосовується глобально без зміни коду інструментування.
return otlpmetrichttp.New(ctx,
otlpmetrichttp.WithAggregationSelector(func(ik sdkmetric.InstrumentKind) sdkmetric.Aggregation {
if ik == sdkmetric.InstrumentKindHistogram {
return sdkmetric.AggregationBase2ExponentialHistogram{}
}
return sdkmetric.DefaultAggregationSelector(ik)
}),
)
}
package otel;
import io.opentelemetry.sdk.metrics.Aggregation;
import io.opentelemetry.sdk.metrics.InstrumentSelector;
import io.opentelemetry.sdk.metrics.SdkMeterProvider;
import io.opentelemetry.sdk.metrics.View;
public class OtelHistogramExponentialView {
static SdkMeterProvider createMeterProvider() {
// Використовуйте view для керування на рівні інструменту — виберіть конкретний інструмент за назвою
// щоб використовувати експоненціальні гістограми, залишаючи явні кошики для інших.
return SdkMeterProvider.builder()
.registerView(
InstrumentSelector.builder().setName("device.command.duration").build(),
View.builder().setAggregation(Aggregation.base2ExponentialBucketHistogram()).build())
.build();
}
}
func createExponentialView() sdkmetric.View {
// Використовуйте view для керування на рівні інструменту — виберіть конкретний інструмент за назвою
// щоб використовувати експоненціальні гістограми, залишаючи явні кошики для інших.
return sdkmetric.NewView(
sdkmetric.Instrument{Name: "device.command.duration"},
sdkmetric.Stream{Aggregation: sdkmetric.AggregationBase2ExponentialHistogram{}!},
)
}
Prometheus
package otel;
import io.prometheus.metrics.core.metrics.Summary;
public class PrometheusSummary {
public static void summaryUsage() {
Summary deviceCommandDuration =
Summary.builder()
.name("device_command_duration_seconds")
.help("Time to receive acknowledgment from a smart home device")
.labelNames("device_type")
.quantile(0.5, 0.05)
.quantile(0.95, 0.01)
.quantile(0.99, 0.001)
.register();
deviceCommandDuration.labelValues("thermostat").observe(0.35);
deviceCommandDuration.labelValues("lock").observe(0.85);
}
}
OpenTelemetry
package otel;
import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.common.Attributes;
import io.opentelemetry.api.metrics.DoubleHistogram;
import io.opentelemetry.api.metrics.Meter;
import java.util.List;
public class OtelHistogramAsSummary {
private static final AttributeKey<String> DEVICE_TYPE = AttributeKey.stringKey("device_type");
private static final Attributes THERMOSTAT = Attributes.of(DEVICE_TYPE, "thermostat");
private static final Attributes LOCK = Attributes.of(DEVICE_TYPE, "lock");
public static void summaryReplacement(OpenTelemetry openTelemetry) {
Meter meter = openTelemetry.getMeter("smart.home");
// Немає явних меж кошиків: фіксує лише кількість і суму, хороший замінник для більшості
// випадків використання Summary. Для оцінки квантилів додайте межі, що охоплюють ваші пороги.
DoubleHistogram deviceCommandDuration =
meter
.histogramBuilder("device.command.duration")
.setDescription("Time to receive acknowledgment from a smart home device")
.setUnit("s")
.setExplicitBucketBoundariesAdvice(List.of())
.build();
deviceCommandDuration.record(0.35, THERMOSTAT);
deviceCommandDuration.record(0.85, LOCK);
}
}
Prometheus
package main
import "github.com/prometheus/client_golang/prometheus"
var summaryDeviceCommandDuration = prometheus.NewSummaryVec(prometheus.SummaryOpts{
Name: "device_command_duration_seconds",
Help: "Time to receive acknowledgment from a smart home device",
Objectives: map[float64]float64{0.5: 0.05, 0.95: 0.01, 0.99: 0.001},
}, []string{"device_type"})
func summaryUsage(reg *prometheus.Registry) {
reg.MustRegister(summaryDeviceCommandDuration)
summaryDeviceCommandDuration.WithLabelValues("thermostat").Observe(0.35)
summaryDeviceCommandDuration.WithLabelValues("lock").Observe(0.85)
}
OpenTelemetry
package main
import (
"context"
"go.opentelemetry.io/otel/attribute"
"go.opentelemetry.io/otel/metric"
)
// Попередньо виділіть параметри атрибутів, коли значення статичні, щоб уникнути виділення пам'яті при кожному виклику.
var (
summaryThermostatOpts = []metric.RecordOption{metric.WithAttributes(attribute.String("device_type", "thermostat"))}
summaryLockOpts = []metric.RecordOption{metric.WithAttributes(attribute.String("device_type", "lock"))}
)
func summaryReplacement(ctx context.Context, meter metric.Meter) {
// Немає явних меж кошиків: фіксує лише кількість і суму, хороший замінник для більшості
// випадків використання Summary. Для оцінки квантилів додайте межі, що охоплюють ваші пороги.
deviceCommandDuration, err := meter.Float64Histogram("device.command.duration",
metric.WithDescription("Time to receive acknowledgment from a smart home device"),
metric.WithUnit("s"),
metric.WithExplicitBucketBoundaries()) // немає меж кошиків
if err != nil {
panic(err)
}
deviceCommandDuration.Record(ctx, 0.35, summaryThermostatOpts...)
deviceCommandDuration.Record(ctx, 0.85, summaryLockOpts...)
}