adding async conversions

Author: Azfaar Qureshi

Diff for: exporter/opentelemetry-exporter-prometheus-remote-write/src/opentelemetry/exporter/prometheus_remote_write/__init__.py

@@ -145,7 +145,7 @@ def export(
         return self.send_message(message, headers)
 
     def shutdown(self) -> None:
-        raise NotImplementedError()
+        pass
 
     def convert_to_timeseries(
         self, export_records: Sequence[ExportRecord]

Diff for: tests/opentelemetry-docker-tests/tests/prometheus-remote-write-cortex/prometheus_remote_write_cortex_test.py

@@ -8,11 +8,11 @@
 from opentelemetry.test.test_base import TestBase
 
 
-def get_cpu_usage_callback(observer):
-    array = [1, 15, 25, 26]
-    for number in array:
-        labels = {"cpu_number": str(number)}
-        observer.observe(int, labels)
+def observer_callback(observer):
+    array = [1.0, 15.0, 25.0, 26.0]
+    for (index, usage) in enumerate(array):
+        labels = {"test_label": str(index)}
+        observer.observe(usage, labels)
 
 
 class TestPrometheusRemoteWriteExporterCortex(TestBase):
@@ -24,55 +24,61 @@ def setUp(self):
             headers={"X-Scope-Org-ID": "5"}
         )
         self.labels = {"environment": "testing"}
+        self.meter = self.meter_provider.get_meter(__name__)
+        metrics.get_meter_provider().start_pipeline(
+            self.meter, self.exporter, 1,
+        )
 
     def test_export_counter(self):
-        meter = self.meter_provider.get_meter(__name__)
-        metrics.get_meter_provider().start_pipeline(meter, self.exporter, 1)
-        requests_counter = meter.create_counter(
+        requests_counter = self.meter.create_counter(
             name="requests_counter",
             description="number of requests",
             unit="1",
             value_type=int,
         )
         requests_counter.add(25, self.labels)
-        # time.sleep(1)
-        # metrics.get_meter_provider().shutdown()
 
     def test_export_valuerecorder(self):
-        meter = self.meter_provider.get_meter(__name__)
-        metrics.get_meter_provider().start_pipeline(meter, self.exporter, 1)
-        requests_size = meter.create_valuerecorder(
+        requests_size = self.meter.create_valuerecorder(
             name="requests_size_valuerecorder",
             description="size of requests",
             unit="1",
             value_type=int,
         )
         requests_size.record(25, self.labels)
-        # time.sleep(1)
-        # metrics.get_meter_provider().shutdown()
 
     def test_export_updowncounter(self):
-        meter = self.meter_provider.get_meter(__name__)
-        metrics.get_meter_provider().start_pipeline(meter, self.exporter, 1)
-        requests_size = meter.create_updowncounter(
+        requests_size = self.meter.create_updowncounter(
             name="requests_active_updowncounter",
             description="active_requests",
             unit="1",
             value_type=int,
         )
         requests_size.add(-25, self.labels)
-        # time.sleep(1)
-        # metrics.get_meter_provider().shutdown()
 
     def test_export_sumobserver(self):
-        meter = self.meter_provider.get_meter(__name__)
-        metrics.get_meter_provider().start_pipeline(meter, self.exporter, 1)
-        meter.register_sumobserver(
-            callback=get_cpu_usage_callback,
+        self.meter.register_sumobserver(
+            callback=observer_callback,
             name="cpu_usage_sumobserver",
             description="per-cpu usage",
             unit="1",
-            value_type=int,
+            value_type=float,
+        )
+
+    def test_export_updownsumobserver(self):
+        self.meter.register_updownsumobserver(
+            callback=observer_callback,
+            name="cpu_usage_updownsumobserver",
+            description="cpu active",
+            unit="1",
+            value_type=float,
         )
-        # time.sleep(2)
-        # metrics.get_meter_provider().shutdown()
+
+    # def test_export_valueobserver(self):
+    #     self.meter.register_valueobserver(
+    #         callback=observer_callback,
+    #         name="ram_usage",
+    #         description="ram memory usage",
+    #         unit="1",
+    #         value_type=float,
+    #     )

Diff for: tox.ini

@@ -198,7 +198,7 @@ commands_pre =
   test: pip install {toxinidir}/opentelemetry-python-core/opentelemetry-api {toxinidir}/opentelemetry-python-core/opentelemetry-sdk {toxinidir}/opentelemetry-python-core/tests/util
 
   test: pip install {toxinidir}/opentelemetry-python-core/opentelemetry-instrumentation
-  
+
   celery: pip install {toxinidir}/instrumentation/opentelemetry-instrumentation-celery[test]
 
   grpc: pip install {toxinidir}/instrumentation/opentelemetry-instrumentation-grpc[test]
@@ -308,7 +308,9 @@ deps =
   sqlalchemy ~= 1.3.16
   redis ~= 3.3.11
   celery ~= 4.0, != 4.4.4
-
+  protobuf>=3.13.0
+  snappy==0.5.4
+  requests==2.25.0
 changedir =
   tests/opentelemetry-docker-tests/tests