opensource/opentelemetry-python-contrib
1
0
Fork 0
mirror of https://github.com/open-telemetry/opentelemetry-python-contrib.git synced 2025-08-02 19:47:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Use public metrics (#1093)

Browse Source
This commit is contained in:
Diego Hurtado
2022-05-16 22:06:08 -06:00
committed by GitHub
parent 80969a06da
commit 9cb853e522
3 changed files with 30 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
instrumentation/opentelemetry-instrumentation-system-metrics/tests/test_system_metrics.py
View File

@ -21,8 +21,8 @@ from unittest import mock
from opentelemetry.instrumentation.system_metrics import (
SystemMetricsInstrumentor,
)
from opentelemetry.sdk._metrics import MeterProvider
from opentelemetry.sdk._metrics.export import InMemoryMetricReader
from opentelemetry.sdk.metrics import MeterProvider
from opentelemetry.sdk.metrics.export import InMemoryMetricReader
from opentelemetry.test.test_base import TestBase
@ -70,8 +70,11 @@ class TestSystemMetrics(TestBase):
meter_provider = MeterProvider(metric_readers=[reader])
system_metrics = SystemMetricsInstrumentor()
system_metrics.instrument(meter_provider=meter_provider)
metrics = reader.get_metrics()
metric_names = list({x.name for x in metrics})
metric_names = []
for resource_metrics in reader.get_metrics_data().resource_metrics:
for scope_metrics in resource_metrics.scope_metrics:
for metric in scope_metrics.metrics:
metric_names.append(metric.name)
self.assertEqual(len(metric_names), 17)
observer_names = [
@ -100,17 +103,22 @@ class TestSystemMetrics(TestBase):
def _assert_metrics(self, observer_name, reader, expected):
assertions = 0
for metric in reader.get_metrics(): # pylint: disable=protected-access
for expect in expected:
if (
metric.attributes == expect.attributes
and metric.name == observer_name
):
self.assertEqual(
metric.point.value,
expect.value,
)
assertions += 1
# pylint: disable=too-many-nested-blocks
for resource_metrics in reader.get_metrics_data().resource_metrics:
for scope_metrics in resource_metrics.scope_metrics:
for metric in scope_metrics.metrics:
for data_point in metric.data.data_points:
for expect in expected:
if (
dict(data_point.attributes)
== expect.attributes
and metric.name == observer_name
):
self.assertEqual(
data_point.value,
expect.value,
)
assertions += 1
self.assertEqual(len(expected), assertions)
def _test_metrics(self, observer_name, expected):