21
21
from opencensus .stats import measure
22
22
from opencensus .stats import stats
23
23
from opencensus .stats import view
24
- import opencensus .tags
24
+ # import opencensus.tags
25
25
26
26
from opencensus .stats .exporters import stackdriver_exporter
27
27
28
28
# [START setup_exporter]
29
29
# Set up the metric to be tracked
30
30
31
31
# Latency of two kinds of simulated operations, "normal" and "extra"
32
- latency_key = opencensus .tags .tag_key .TagKey ('kind' )
32
+ # latency_key = opencensus.tags.tag_key.TagKey('kind')
33
33
34
34
# Measure in milliseconds
35
35
latency_measure = measure .MeasureFloat ('latency' , 'Latency in ms' , 'ms' )
42
42
latency_view = view .View (
43
43
'latency' ,
44
44
'Processing time' ,
45
- [latency_key ],
45
+ # [latency_key],
46
+ [],
46
47
latency_measure ,
47
48
latency_distribution
48
49
)
@@ -70,6 +71,8 @@ def process(kind):
70
71
71
72
72
73
def main (iteration_count ):
74
+ measure_map = recorder .new_measurement_map ()
75
+ #tag_map = opencensus.tags.TagMap()
73
76
74
77
# Simulated processing normally takes up to 1000 ms, randomly distributed.
75
78
# Ten percent of the time, simulated "extra" processing adds 500ms
@@ -86,13 +89,11 @@ def main(iteration_count):
86
89
duration = time .time () - start_time
87
90
88
91
# Record the measurement
89
- measure_map = recorder .new_measurement_map ()
90
92
measure_map .measure_float_put (latency_measure , duration )
91
- tag_map = opencensus .tags .TagMap ()
92
- tag_map .insert (latency_key , opencensus .tags .tag_value .TagValue (kind ))
93
+ #tag_map.insert(latency_key, opencensus.tags.tag_value.TagValue(kind))
93
94
print (duration )
94
95
95
- measure_map .record (tag_map )
96
+ measure_map .record ()
96
97
time .sleep (60 )
97
98
# [END monitoring_opencensus_metrics_quickstart]
98
99
0 commit comments