Implement Azure Metrics Exporter (#693)

Author: lzchen

contrib/opencensus-ext-azure/README.rst

@@ -72,7 +72,7 @@ You can enrich the logs with trace IDs and span IDs by using the `logging integr
 Metrics
 ~~~~~~~
 
-The **OpenCensus Azure Monitor Metrics Exporter** allows you to export metrics to `Azure Monitor`_.
+The **Azure Monitor Metrics Exporter** allows you to export metrics to `Azure Monitor`_.
 
 * Create an Azure Monitor resource and get the instrumentation key, more information can be found `here <https://docs.microsoft.com/azure/azure-monitor/app/create-new-resource>`_.
 * Put the instrumentation key in ``APPINSIGHTS_INSTRUMENTATIONKEY`` environment variable.
@@ -109,7 +109,7 @@ Using the Metrics exporter
         def main():
             # Enable metrics
             # Set the interval in seconds in which you want to send metrics
-            exporter = metrics_exporter.new_metrics_exporter(export_interval=2)
+            exporter = metrics_exporter.new_metrics_exporter()
             view_manager.register_exporter(exporter)
 
             view_manager.register_view(CARROTS_VIEW)
@@ -118,7 +118,11 @@ Using the Metrics exporter
 
             mmap.measure_int_put(CARROTS_MEASURE, 1000)
             mmap.record(tmap)
-            time.sleep(10)
+            # Default export interval is every 15.0s
+            # Your application should run for at least this amount
+            # of time so the exporter will meet this interval
+            # Sleep can fulfill this
+            time.sleep(60)
 
             print("Done recording metrics")
 

contrib/opencensus-ext-azure/examples/metrics/distribution.py

@@ -38,7 +38,7 @@
 def main():
     # Enable metrics
     # Set the interval in seconds in which you want to send metrics
-    exporter = metrics_exporter.new_metrics_exporter(export_interval=2)
+    exporter = metrics_exporter.new_metrics_exporter()
     view_manager.register_exporter(exporter)
 
     view_manager.register_view(CARROTS_VIEW)
@@ -47,7 +47,7 @@ def main():
 
     mmap.measure_int_put(CARROTS_MEASURE, 1000)
     mmap.record(tmap)
-    time.sleep(10)
+    time.sleep(60)
 
     print("Done recording metrics")
 

contrib/opencensus-ext-azure/examples/metrics/simple.py

@@ -25,29 +25,30 @@
 view_manager = stats.view_manager
 stats_recorder = stats.stats_recorder
 
-CHIPS_EATEN_MEASURE = measure_module.MeasureFloat("chips_eaten",
-                                                  "number of chips eaten",
-                                                  "chips")
-CHIPS_EATEN_VIEW = view_module.View("chips_eaten_view",
-                                    "number of chips eaten",
-                                    [],
-                                    CHIPS_EATEN_MEASURE,
-                                    aggregation_module.SumAggregation())
+REQUEST_MEASURE = measure_module.MeasureFloat("Requests",
+                                              "number of requests",
+                                              "requests")
+NUM_REQUESTS_VIEW = view_module.View("Number of Requests",
+                                     "number of requests",
+                                     ["url"],
+                                     REQUEST_MEASURE,
+                                     aggregation_module.SumAggregation())
 
 
 def main():
     # Enable metrics
     # Set the interval in seconds in which you want to send metrics
-    exporter = metrics_exporter.new_metrics_exporter(export_interval=5)
+    exporter = metrics_exporter.new_metrics_exporter()
     view_manager.register_exporter(exporter)
 
-    view_manager.register_view(CHIPS_EATEN_VIEW)
+    view_manager.register_view(NUM_REQUESTS_VIEW)
     mmap = stats_recorder.new_measurement_map()
     tmap = tag_map_module.TagMap()
+    tmap.insert("url", "http://example.com")
 
     for i in range(100):
         print(i)
-        mmap.measure_int_put(CHIPS_EATEN_MEASURE, 1)
+        mmap.measure_int_put(REQUEST_MEASURE, i)
         mmap.record(tmap)
         time.sleep(1)
 

contrib/opencensus-ext-azure/examples/metrics/sum.py

@@ -65,6 +65,24 @@ def __init__(self, *args, **kwargs):
         self.baseType = self.baseType
 
 
+class DataPoint(BaseObject):
+    _default = BaseObject(
+        ns='',
+        name='',
+        kind=None,
+        value=0.0,
+        count=None,
+        min=None,
+        max=None,
+        stdDev=None,
+    )
+
+    def __init__(self, *args, **kwargs):
+        super(DataPoint, self).__init__(*args, **kwargs)
+        self.name = self.name
+        self.value = self.value
+
+
 class Envelope(BaseObject):
     _default = BaseObject(
         ver=1,
@@ -129,6 +147,19 @@ def __init__(self, *args, **kwargs):
         self.message = self.message
 
 
+class MetricData(BaseObject):
+    _default = BaseObject(
+        ver=2,
+        metrics=[],
+        properties=None,
+    )
+
+    def __init__(self, *args, **kwargs):
+        super(MetricData, self).__init__(*args, **kwargs)
+        self.ver = self.ver
+        self.metrics = self.metrics
+
+
 class RemoteDependency(BaseObject):
     _default = BaseObject(
         ver=2,