lzchen · lzchen · Jul 29, 2019 · Jul 31, 2019 · Jul 31, 2019 · Jul 31, 2019
diff --git a/docs/opentelemetry.metrics.handle.rst b/docs/opentelemetry.metrics.handle.rst
diff --git a/docs/opentelemetry.metrics.rst b/docs/opentelemetry.metrics.rst
@@ -1,13 +1,6 @@
 opentelemetry.metrics package
 =============================
 
-Submodules
-----------
-
-.. toctree::
-
-   opentelemetry.metrics.handle
-
 Module contents
 ---------------
 

diff --git a/...src/opentelemetry/metrics/examples/raw.py → ...ntelemetry_example_app/metrics_example.py b/...src/opentelemetry/metrics/examples/raw.py → ...ntelemetry_example_app/metrics_example.py
@@ -11,26 +11,32 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+#
+"""
+This module serves as an example for a simple application using metrics
+"""
 
-# pylint: skip-file
 from opentelemetry import metrics
+from opentelemetry.sdk.metrics import Meter
 
-METER = metrics.Meter()
-MEASURE = metrics.create_measure(
-    "idle_cpu_percentage",
-    "cpu idle over time",
-    "percentage",
-    metrics.ValueType.FLOAT,
-    ["environment"],
+metrics.set_preferred_meter_implementation(lambda _: Meter())
+meter = metrics.meter()
+counter = meter.create_metric(
+    "available memory",
+    "available memory",
+    "bytes",
+    int,
+    metrics.MetricKind.COUNTER,
+    ("environment"),
 )
 
-# Metrics sent to some exporter
-MEASURE_METRIC_TESTING = MEASURE.get_handle("Testing")
-MEASURE_METRIC_STAGING = MEASURE.get_handle("Staging")
+label_values = "staging"
+
+counter_handle = counter.get_handle(label_values)
+
+counter_handle.add(100)
+meter.record_batch(label_values, [(counter, 50)])
 
-# record individual measures
-STATISTIC = 100
-MEASURE_METRIC_STAGING.record(STATISTIC)
+print(counter_handle.data)
 
-# Batch recording
-METER.record_batch([tuple(MEASURE_METRIC_STAGING, STATISTIC)])
+# TODO: exporters
diff --git a/ext/opentelemetry-ext-azure-monitor/examples/metrics.py b/ext/opentelemetry-ext-azure-monitor/examples/metrics.py
@@ -0,0 +1,42 @@
+# Copyright 2019, OpenCensus Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import logging
+
+from opentelemetry import metrics
+from opentelemetry.ext.azure_monitor import AzureMonitorMetricsExporter
+from opentelemetry.sdk.metrics import Counter, Meter
+from opentelemetry.sdk.metrics.export import ConsoleMetricsExporter
+
+logging.basicConfig(level=logging.INFO)
+
+metrics.set_preferred_meter_implementation(lambda T: Meter())
+meter = metrics.meter()
+exporter = AzureMonitorMetricsExporter()
+console_exporter = ConsoleMetricsExporter()
+
+counter = meter.create_metric(
+    "available memory",
+    "available memory",
+    "bytes",
+    int,
+    Counter,
+    ("environment",),
+)
+label_values = ("staging",)
+counter_handle = counter.get_handle(label_values)
+counter_handle.add(100)
+
+console_exporter.export([(counter, label_values)])
+exporter.export([(counter, label_values)])
diff --git a/ext/opentelemetry-ext-azure-monitor/src/opentelemetry/ext/azure_monitor/__init__.py b/ext/opentelemetry-ext-azure-monitor/src/opentelemetry/ext/azure_monitor/__init__.py
@@ -16,8 +16,8 @@
 The opentelemetry-ext-azure-monitor package provides integration with
 Microsoft Azure Monitor.
 """
-
+from opentelemetry.ext.azure_monitor.metrics import AzureMonitorMetricsExporter
 from opentelemetry.ext.azure_monitor.trace import AzureMonitorSpanExporter
 from opentelemetry.ext.azure_monitor.version import __version__  # noqa
 
-__all__ = ["AzureMonitorSpanExporter"]
+__all__ = ["AzureMonitorMetricsExporter", "AzureMonitorSpanExporter"]
diff --git a/ext/opentelemetry-ext-azure-monitor/src/opentelemetry/ext/azure_monitor/metrics.py b/ext/opentelemetry-ext-azure-monitor/src/opentelemetry/ext/azure_monitor/metrics.py
@@ -0,0 +1,98 @@
+# Copyright 2019, OpenTelemetry Authors
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import json
+import logging
+
+import requests
+
+from opentelemetry.ext.azure_monitor import protocol, util
+from opentelemetry.sdk.metrics.export import MetricsExporter,\
+    MetricsExportResult
+
+
+logger = logging.getLogger(__name__)
+
+
+class AzureMonitorMetricsExporter(MetricsExporter):
+    def __init__(self, **options):
+        self.options = util.Options(**options)
+        if not self.options.instrumentation_key:
+            raise ValueError("The instrumentation_key is not provided.")
+
+    def export(self, metric_tuples):
+        envelopes = tuple(map(self.metric_tuple_to_envelope, metric_tuples))
+
+        try:
+            response = requests.post(
+                url=self.options.endpoint,
+                data=json.dumps(envelopes),
+                headers={
+                    "Accept": "application/json",
+                    "Content-Type": "application/json; charset=utf-8",
+                },
+                timeout=self.options.timeout,
+            )
+        except requests.RequestException as ex:
+            logger.warning("Transient client side error %s.", ex)
+            return MetricsExportResult.FAILED_RETRYABLE
+
+        text = "N/A"
+        data = None  # noqa pylint: disable=unused-variable
+        try:
+            text = response.text
+        except Exception as ex:  # noqa pylint: disable=broad-except
+            logger.warning("Error while reading response body %s.", ex)
+        else:
+            try:
+                data = json.loads(text)  # noqa pylint: disable=unused-variable
+            except Exception:  # noqa pylint: disable=broad-except
+                pass
+
+        if response.status_code == 200:
+            logger.info("Transmission succeeded: %s.", text)
+            return MetricsExportResult.SUCCESS
+
+        if response.status_code in (
+            206,  # Partial Content
+            429,  # Too Many Requests
+            500,  # Internal Server Error
+            503,  # Service Unavailable
+        ):
+            return MetricsExportResult.FAILED_RETRYABLE
+
+        return MetricsExportResult.FAILED_NOT_RETRYABLE
+
+    def metric_tuple_to_envelope(self, metric_tuple):
+        metric = metric_tuple[0]
+        label_values = metric_tuple[1]
+        handle = metric.get_handle(label_values)
+        envelope = protocol.Envelope(
+            iKey=self.options.instrumentation_key,
+            tags=dict(util.azure_monitor_context),
+            time=handle.time_stamp.isoformat(),
+        )
+        envelope.name = "Microsoft.ApplicationInsights.Metric"
+        # label_keys and label_values assumed to have the same length
+        properties = {metric.label_keys[idx]: label_values[idx]
+            for idx, value in enumerate(label_values, start=0)}
+        data_point = protocol.DataPoint(ns=metric.name,
+                                   name=metric.name,
+                                   value=handle.data)
+        data = protocol.MetricData(
+            metrics=[data_point],
+            properties=properties
+        )
+        envelope.data = protocol.Data(baseData=data, baseType="MetricData")
+        return envelope