Add timestamps to aggregators and OTLP metrics exporter (#1199)

Author: ocelotl

exporter/opentelemetry-exporter-otlp/CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+- Add timestamps to OTLP exporter
+  ([#1199](https://github.com/open-telemetry/opentelemetry-python/pull/1199))
 - Update OpenTelemetry protos to v0.5.0
   ([#1143](https://github.com/open-telemetry/opentelemetry-python/pull/1143))
 

exporter/opentelemetry-exporter-otlp/src/opentelemetry/exporter/otlp/metrics_exporter/__init__.py

@@ -85,6 +85,12 @@ def _get_data_points(
                     data_point_class(
                         labels=string_key_values,
                         value=view_data.aggregator.current,
+                        start_time_unix_nano=(
+                            view_data.aggregator.last_checkpoint_timestamp
+                        ),
+                        time_unix_nano=(
+                            view_data.aggregator.last_update_timestamp
+                        ),
                     )
                 )
                 break

exporter/opentelemetry-exporter-otlp/tests/test_otlp_metric_exporter.py

@@ -14,6 +14,7 @@
 
 from collections import OrderedDict
 from unittest import TestCase
+from unittest.mock import patch
 
 from opentelemetry.exporter.otlp.metrics_exporter import OTLPMetricsExporter
 from opentelemetry.proto.collector.metrics.v1.metrics_service_pb2 import (
@@ -59,9 +60,12 @@ def setUp(self):
             resource,
         )
 
-    def test_translate_metrics(self):
+    @patch("opentelemetry.sdk.metrics.export.aggregate.time_ns")
+    def test_translate_metrics(self, mock_time_ns):
         # pylint: disable=no-member
 
+        mock_time_ns.configure_mock(**{"return_value": 1})
+
         self.counter_metric_record.instrument.add(1, OrderedDict([("a", "b")]))
 
         expected = ExportMetricsServiceRequest(
@@ -91,6 +95,7 @@ def test_translate_metrics(self):
                                                     )
                                                 ],
                                                 value=1,
+                                                time_unix_nano=1,
                                             )
                                         ],
                                         aggregation_temporality=(

opentelemetry-sdk/CHANGELOG.md

@@ -2,6 +2,8 @@
 
 ## Unreleased
 
+- Add timestamps to aggregators
+  ([#1199](https://github.com/open-telemetry/opentelemetry-python/pull/1199))
 - Add Global Error Handler
   ([#1080](https://github.com/open-telemetry/opentelemetry-python/pull/1080))
 - Update sampling result names