feat(origindetection): implement cardinality common field

Signed-off-by: Wassim DHIF <wassim.dhif@datadoghq.com>

Author: wdhif

datadog/__init__.py

@@ -46,6 +46,7 @@ def initialize(
     statsd_constant_tags=None,  # type: Optional[List[str]]
     return_raw_response=False,  # type: bool
     hostname_from_config=True,  # type: bool
+    cardinality=None,  # type: Optional[str]
     **kwargs  # type: Any
 ):
     # type: (...) -> None
@@ -112,6 +113,12 @@ def initialize(
 
     :param hostname_from_config: Set the hostname from the Datadog agent config (agent 5). Will be deprecated
     :type hostname_from_config: boolean
+
+    :param cardinality: Set the global cardinality for all metrics. \
+        Possible values are "none", "low", "orchestrator" and "high".
+        Can also be set via the DATADOG_CARDINALITY or DD_CARDINALITY environment variables.
+    :type cardinality: string
+
     """
     # API configuration
     api._api_key = api_key or api._api_key or os.environ.get("DATADOG_API_KEY", os.environ.get("DD_API_KEY"))
@@ -146,6 +153,9 @@ def initialize(
     statsd.disable_buffering = statsd_disable_buffering
     api._return_raw_response = return_raw_response
 
+    # Set the global cardinality for all metrics
+    statsd.cardinality = cardinality or os.environ.get("DATADOG_CARDINALITY", os.environ.get("DD_CARDINALITY"))
+
     # HTTP client and API options
     for key, value in iteritems(kwargs):
         attribute = "_{}".format(key)

datadog/dogstatsd/aggregator.py

@@ -34,29 +34,29 @@ def get_context(self, name, tags):
         tags_str = ",".join(tags) if tags is not None else ""
         return "{}:{}".format(name, tags_str)
 
-    def count(self, name, value, tags, rate, timestamp=0):
+    def count(self, name, value, tags, rate, timestamp=0, cardinality=None):
         return self.add_metric(
-            MetricType.COUNT, CountMetric, name, value, tags, rate, timestamp
+            MetricType.COUNT, CountMetric, name, value, tags, rate, timestamp, cardinality
         )
 
-    def gauge(self, name, value, tags, rate, timestamp=0):
+    def gauge(self, name, value, tags, rate, timestamp=0, cardinality=None):
         return self.add_metric(
-            MetricType.GAUGE, GaugeMetric, name, value, tags, rate, timestamp
+            MetricType.GAUGE, GaugeMetric, name, value, tags, rate, timestamp, cardinality
         )
 
-    def set(self, name, value, tags, rate, timestamp=0):
+    def set(self, name, value, tags, rate, timestamp=0, cardinality=None):
         return self.add_metric(
-            MetricType.SET, SetMetric, name, value, tags, rate, timestamp
+            MetricType.SET, SetMetric, name, value, tags, rate, timestamp, cardinality
         )
 
     def add_metric(
-        self, metric_type, metric_class, name, value, tags, rate, timestamp=0
+        self, metric_type, metric_class, name, value, tags, rate, timestamp=0, cardinality=None
     ):
         context = self.get_context(name, tags)
         with self._locks[metric_type]:
             if context in self.metrics_map[metric_type]:
                 self.metrics_map[metric_type][context].aggregate(value)
             else:
                 self.metrics_map[metric_type][context] = metric_class(
-                    name, value, tags, rate, timestamp
+                    name, value, tags, rate, timestamp, cardinality
                 )