forked from DataDog/datadogpy
-
Notifications
You must be signed in to change notification settings - Fork 0
/
distributions.py
45 lines (40 loc) · 1.85 KB
/
distributions.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
# Unless explicitly stated otherwise all files in this repository are licensed under the BSD-3-Clause License.
# This product includes software developed at Datadog (https://www.datadoghq.com/).
# Copyright 2015-Present Datadog, Inc
# datadog
from datadog.api.format import format_points
from datadog.api.resources import SendableAPIResource
class Distribution(SendableAPIResource):
"""A wrapper around Distribution HTTP API"""
_resource_name = "distribution_points"
@classmethod
def send(cls, distributions=None, attach_host_name=True, compress_payload=False, **distribution):
"""
Submit a distribution metric or a list of distribution metrics to the distribution metric
API
:param compress_payload: compress the payload using zlib
:type compress_payload: bool
:param metric: the name of the time series
:type metric: string
:param points: a (timestamp, [list of values]) pair or
list of (timestamp, [list of values]) pairs
:type points: list
:param host: host name that produced the metric
:type host: string
:param tags: list of tags associated with the metric.
:type tags: string list
:returns: Dictionary representing the API's JSON response
"""
if distributions:
# Multiple distributions are sent
for d in distributions:
if isinstance(d, dict):
d["points"] = format_points(d["points"])
series_dict = {"series": distributions}
else:
# One distribution is sent
distribution["points"] = format_points(distribution["points"])
series_dict = {"series": [distribution]}
return super(Distribution, cls).send(
attach_host_name=attach_host_name, compress_payload=compress_payload, **series_dict
)