File tree Expand file tree Collapse file tree 3 files changed +15
-6
lines changed
opentelemetry-sdk/src/opentelemetry/sdk/_metrics/export Expand file tree Collapse file tree 3 files changed +15
-6
lines changed Original file line number Diff line number Diff line change 3
3
OTLPMetricExporter ,
4
4
)
5
5
from opentelemetry .sdk ._metrics import MeterProvider
6
+ from opentelemetry .sdk ._metrics .export import PeriodicExportingMetricReader
6
7
7
- provider = MeterProvider ()
8
8
exporter = OTLPMetricExporter (insecure = True )
9
- # TODO: fill in details for metric reader
9
+ reader = PeriodicExportingMetricReader (exporter )
10
+ provider = MeterProvider (metric_readers = [reader ])
10
11
set_meter_provider (provider )
11
12
12
13
meter = get_meter_provider ().get_meter ("getting-started" )
13
14
counter = meter .create_counter ("first_counter" )
15
+ counter .add (1 )
14
16
# TODO: fill in details for additional metrics
Original file line number Diff line number Diff line change 17
17
18
18
from opentelemetry ._metrics import get_meter_provider , set_meter_provider
19
19
from opentelemetry .sdk ._metrics import MeterProvider
20
- from opentelemetry .sdk ._metrics .export import ConsoleMetricExporter
20
+ from opentelemetry .sdk ._metrics .export import (
21
+ ConsoleMetricExporter ,
22
+ PeriodicExportingMetricReader ,
23
+ )
21
24
22
- provider = MeterProvider ()
23
25
exporter = ConsoleMetricExporter ()
24
- # TODO: fill in details for metric reader
26
+ reader = PeriodicExportingMetricReader (exporter )
27
+ provider = MeterProvider (metric_readers = [reader ])
25
28
set_meter_provider (provider )
26
29
27
30
meter = get_meter_provider ().get_meter ("getting-started" )
28
31
counter = meter .create_counter ("first_counter" )
32
+ counter .add (1 )
29
33
# TODO: fill in details for additional metrics
Original file line number Diff line number Diff line change @@ -154,6 +154,8 @@ def _ticker(self) -> None:
154
154
self .collect ()
155
155
156
156
def _receive_metrics (self , metrics : Iterable [Metric ]) -> None :
157
+ if metrics is None :
158
+ return
157
159
token = attach (set_value (_SUPPRESS_INSTRUMENTATION_KEY , True ))
158
160
try :
159
161
self ._exporter .export (metrics )
@@ -172,4 +174,5 @@ def _shutdown():
172
174
173
175
self ._shutdown_event .set ()
174
176
self ._daemon_thread .join ()
175
- return self ._exporter .shutdown ()
177
+ self ._exporter .shutdown ()
178
+ return True
You can’t perform that action at this time.
0 commit comments