Envoi de métriques : DogStatsD

Si StatsD n’accepte que les métriques, DogStatsD prend en charge les trois principaux types de données Datadog : métriques, événements et checks de service. Cette section propose des cas d’utilisation typiques des métriques, présentés par types de métrique, et décrit les options de taux d’échantillonnage et de tagging de métriques spécifiques à DogStatsD.

Les utilisateurs de StatsD connaissent déjà les métriques COUNT, GAUGE et SET. Les métriques TIMER de StatsD sont un sous-ensemble des métriques HISTOGRAM de DogStatsD. En outre, vous pouvez envoyer des métriques de type HISTOGRAM et DISTRIBUTION avec DogStatsD.

Remarque : selon la méthode d’envoi utilisée, le type de métrique stocké dans Datadog peut être différent du type de métrique envoyé. Lorsque vous envoyez une métrique de type RATE via DogStatsD, la métrique affichée dans l’application possède le type GAUGE, afin de garantir la pertinence des comparaisons entre les différents Agents.

Fonctions

Après avoir installé DogStatsD, vous pouvez utiliser les différentes fonctions ci-dessous pour envoyer vos métriques à Datadog. Choisissez une fonction selon le type de vos métriques. Ces fonctions ont les paramètres suivants en commun :

ParamètreTypeObligatoireDescription
<NOM_MÉTRIQUE>ChaîneOuiLe nom de la métrique à envoyer.
<VALEUR_MÉTRIQUE>DoubleOuiLa valeur associée à votre métrique.
<TAUX_ÉCHANTILLONNAGE>DoubleNonLe taux d’échantillonnage à appliquer à votre métrique. Toutes les valeurs comprises entre 0 (tout est échantillonné et rien n’est envoyé) à 1 (pas d’échantillonnage) sont acceptées. Pour en savoir plus, consultez la section sur les taux d’échantillonnage.
<TAGS>Liste de chaînesNonLa liste des tags à appliquer à la métrique. Pour en savoir plus, consultez la section sur le tagging de métriques.

COUNT

increment(<NOM_MÉTRIQUE>, <VALEUR_MÉTRIQUE>, <TAGS>)
Permet d’incrémenter une métrique COUNT. La métrique est stockée en tant que RATE dans Datadog. Chaque valeur de la série temporelle stockée correspond au delta normalisé de la valeur de la métrique durant la période de transmission de StatsD.
decrement(<NOM_MÉTRIQUE>, <TAUX_ÉCHANTILLONNAGE>, <TAGS>)
Permet de décrémenter une métrique COUNT. La métrique est stockée en tant que RATE dans Datadog. Chaque valeur de la série temporelle stockée correspond au delta normalisé de la valeur de la métrique durant la période de transmission de StatsD.
count(<NOM_MÉTRIQUE>, <VALEUR_MÉTRIQUE>, <TAUX_ÉCHANTILLONNAGE>, <TAGS>)
Permet d’incrémenter une métrique COUNT à partir d’une Value arbitraire. La métrique est stockée en tant que RATE dans Datadog. Chaque valeur de la série temporelle stockée correspond au delta normalisé de la valeur de la métrique durant la période de transmission de StatsD.
Remarque : la fonction count n’est pas prise en charge par Python.

Remarque : Datadog peut afficher les métriques de type COUNT avec une valeur décimale, car elles sont normalisées sur l’intervalle de transmission et indiquées en unités par seconde.

Exemples de code

Dans cet exemple, une métrique COUNT stockée en tant que métrique RATE est envoyée à Datadog. Pour en savoir plus sur le type COUNT, consultez la documentation sur les types de métrique.

Exécutez le code suivant pour envoyer une métrique COUNT DogStatsD à Datadog. N’oubliez pas de flush/close le client une fois sa mission accomplie.

from datadog import initialize, statsd
import time

options = {
    'statsd_host':'127.0.0.1',
    'statsd_port':8125
}

initialize(**options)

while(1):
  statsd.increment('exemple_métrique.increment', tags=["environment:dev"])
  statsd.decrement('exemple_métrique.decrement', tags=["environment:dev"])
  time.sleep(10)

Remarque : statsd.count n’est pas pris en charge par Python.

require 'datadog/statsd'

statsd = Datadog::Statsd.new('localhost', 8125, tags: ['environment:dev'])

while true do
    statsd.increment('example_metric.increment')
    statsd.increment('example_metric.increment', tags: ['another:tag'])
    statsd.decrement('example_metric.decrement')
    statsd.count('example_metric.count', 2)
    sleep 10
end

package main

import (
    "log"
    "time"

    "github.com/DataDog/datadog-go/statsd"
)

func main() {
    statsd, err := statsd.New("127.0.0.1:8125")
    if err != nil {
        log.Fatal(err)
    }
    for {

        statsd.Incr("exemple_métrique.increment", []string{"environment:dev"}, 1)
        statsd.Decr("exemple_métrique.decrement", []string{"environment:dev"}, 1)
        statsd.Count("exemple_métrique.count", 2, []string{"environment:dev"}, 1)
        time.Sleep(10 * time.Second)
    }
}

import com.timgroup.statsd.NonBlockingStatsDClientBuilder;
import com.timgroup.statsd.StatsDClient;
import java.util.Random;

public class DogStatsdClient {

    public static void main(String[] args) throws Exception {

        StatsDClient Statsd = new NonBlockingStatsDClientBuilder()
            .prefix("statsd")
            .hostname("localhost")
            .port(8125)
            .build();
        for (int i = 0; i < 10; i++) {
            Statsd.incrementCounter("exemple_métrique.increment", new String[]{"environment:dev"});
            Statsd.decrementCounter("exemple_métrique.decrement", new String[]{"environment:dev"});
            Statsd.count("exemple_métrique.count", 2, new String[]{"environment:dev"});
            Thread.sleep(100000);
        }
    }
}

using StatsdClient;
using System;

public class DogStatsdClient
{
    public static void Main()
    {
        var dogstatsdConfig = new StatsdConfig
        {
            StatsdServerName = "127.0.0.1",
            StatsdPort = 8125,
        };

        using (var dogStatsdService = new DogStatsdService())
        {
            if (!dogStatsdService.Configure(dogstatsdConfig))
                throw new InvalidOperationException("Cannot initialize DogstatsD. Set optionalExceptionHandler argument in the `Configure` method for more information.");
            var random = new Random(0);

            for (int i = 0; i < 10; i--)
            {
                dogStatsdService.Increment("example_metric.increment", tags: new[] {"environment:dev"});
                dogStatsdService.Decrement("example_metric.decrement", tags: new[] {"environment:dev"});
                dogStatsdService.Counter("example_metric.count", 2, tags: new[] {"environment:dev"});
                System.Threading.Thread.Sleep(random.Next(100000));
            }
        }
    }
}

<?php

require __DIR__ . '/vendor/autoload.php';

use DataDog\DogStatsd;

$statsd = new DogStatsd(
    array('host' => '127.0.0.1',
          'port' => 8125,
     )
  );

while (TRUE) {
    $statsd->increment('exemple_métrique.increment', 1, array('environment'=>'dev'));
    $statsd->decrement('exemple_métrique.decrement', 1, array('environment'=>'dev'));
    sleep(10);
}

Une fois le code ci-dessus exécuté, les données de vos métriques peuvent être représentées graphiquement dans Datadog :

Incrémenter décrémenter

La valeur étant envoyée en tant que COUNT, elle est stockée en tant que RATE dans Datadog. Pour récupérer des counts bruts dans Datadog, appliquez une fonction à votre série, telle que la fonction Somme cumulée ou Intégrale :

Incrémenter/décrémenter avec somme cumulée

GAUGE

gauge(<NOM_MÉTRIQUE>, <VALEUR_MÉTRIQUE>, <TAUX_ÉCHANTILLONNAGE>, <TAGS>)
La métrique est stockée en tant que GAUGE dans Datadog. Chaque valeur de la série temporelle stockée correspond à la dernière valeur gauge envoyée pour cette métrique durant l’intervalle de transmission de StatsD.

Exemples de code

Dans cet exemple, une métrique GAUGE stockée en tant que métrique GAUGE est envoyée à Datadog. Pour en savoir plus sur le type GAUGE, consultez la documentation sur les types de métrique.

Exécutez le code suivant pour envoyer une métrique GAUGE DogStatsD à Datadog. N’oubliez pas de flush/close le client une fois sa mission accomplie.

Remarque : l’envoi de métriques se fait à l’aide d’appels asynchrones. Pour vérifier que les métriques sont envoyées, appelez flush avant de quitter le programme.

from datadog import initialize, statsd
import time

options = {
    'statsd_host':'127.0.0.1',
    'statsd_port':8125
}

initialize(**options)

i = 0

while(1):
  i += 1
  statsd.gauge('exemple_métrique.gauge', i, tags=["environment:dev"])
  time.sleep(10)

require 'datadog/statsd'

statsd = Datadog::Statsd.new('localhost', 8125)

i = 0

while true do
    i += 1
    statsd.gauge('exemple_métrique.gauge', i, tags: ['environment:dev'])
    sleep 10
end

package main

import (
    "log"
    "time"

    "github.com/DataDog/datadog-go/statsd"
)

func main() {
    statsd, err := statsd.New("127.0.0.1:8125")
    if err != nil {
        log.Fatal(err)
    }
    var i float64
    for {
        i += 1
        statsd.Gauge("exemple_métrique.gauge", i, []string{"environment:dev"}, 1)
        time.Sleep(10 * time.Second)
    }
}

import com.timgroup.statsd.NonBlockingStatsDClientBuilder;
import com.timgroup.statsd.StatsDClient;
import java.util.Random;

public class DogStatsdClient {

    public static void main(String[] args) throws Exception {

        StatsDClient Statsd = new NonBlockingStatsDClientBuilder()
            .prefix("statsd").
            .hostname("localhost")
            .port(8125)
            .build();
        for (int i = 0; i < 10; i++) {
            Statsd.recordGaugeValue("exemple_métrique.gauge", i, new String[]{"environment:dev"});
            Thread.sleep(10000);
        }
    }
}

using StatsdClient;
using System;

public class DogStatsdClient
{
    public static void Main()
    {
        var dogstatsdConfig = new StatsdConfig
        {
            StatsdServerName = "127.0.0.1",
            StatsdPort = 8125,
        };

        using (var dogStatsdService = new DogStatsdService())
        {
            if (!dogStatsdService.Configure(dogstatsdConfig))
                throw new InvalidOperationException("Cannot initialize DogstatsD. Set optionalExceptionHandler argument in the `Configure` method for more information.");
            var random = new Random(0);

            for (int i = 0; i < 10; i--)
            {
                dogStatsdService.Gauge("example_metric.gauge", i, tags: new[] {"environment:dev"});
                System.Threading.Thread.Sleep(100000);
            }
        }
    }
}

<?php

require __DIR__ . '/vendor/autoload.php';

use DataDog\DogStatsd;

$statsd = new DogStatsd(
    array('host' => '127.0.0.1',
          'port' => 8125,
     )
  );

$i = 0;
while (TRUE) {
    $i++;
    $statsd->gauge('exemple_métrique.gauge', $i, array('environment'=>'dev'));
    sleep(10);
}

Une fois le code ci-dessus exécuté, les données de votre métrique peuvent être représentées graphiquement dans Datadog :

Gauge

SET

set(<NOM_MÉTRIQUE>, <VALEUR_MÉTRIQUE>, <TAUX_ÉCHANTILLONNAGE>, <TAGS>)
La métrique est stockée en tant que GAUGE dans Datadog. Chaque valeur de la série temporelle stockée correspond au nombre de valeurs uniques envoyées par StatsD pour une métrique lors de l’intervalle de transmission.

Exemples de code

Envoyer une métrique SET stockée en tant que métrique GAUGE à Datadog.

Exécutez le code suivant pour envoyer une métrique SET DogStatsD à Datadog. N’oubliez pas de flush/close le client une fois sa mission accomplie.

from datadog import initialize, statsd
import time
import random

options = {
    'statsd_host':'127.0.0.1',
    'statsd_port':8125
}

initialize(**options)
i = 0
while(1):
  i += 1
  statsd.set('exemple_métrique.set', i, tags=["environment:dev"])
  time.sleep(random.randint(0, 10))

require 'datadog/statsd'

statsd = Datadog::Statsd.new('localhost', 8125)

i = 0
while true do
    i += 1
    statsd.set('exemple_métrique.gauge', i, tags: ['environment:dev'])
    sleep rand 10
end

package main

import (
    "fmt"
    "log"
    "math/rand"
    "time"

    "github.com/DataDog/datadog-go/statsd"
)

func main() {
    statsd, err := statsd.New("127.0.0.1:8125")
    if err != nil {
        log.Fatal(err)
    }
    var i float64
    for {
        i += 1
        statsd.Set("example_metric.set", fmt.Sprintf("%f", i), []string{"environment:dev"}, 1)
        time.Sleep(time.Duration(rand.Intn(10)) * time.Second)
    }
}

import com.timgroup.statsd.NonBlockingStatsDClientBuilder;
import com.timgroup.statsd.StatsDClient;
import java.util.Random;

public class DogStatsdClient {

    public static void main(String[] args) throws Exception {

        StatsDClient Statsd = new NonBlockingStatsDClientBuilder()
            .prefix("statsd").
            .hostname("localhost")
            .port(8125)
            .build();
        for (int i = 0; i < 10; i++) {
            Statsd.recordSetValue("example_metric.set", i, new String[]{"environment:dev"});
            Thread.sleep(random.NextInt(10000));
        }
    }
}

using StatsdClient;
using System;

public class DogStatsdClient
{
    public static void Main()
    {
        var dogstatsdConfig = new StatsdConfig
        {
            StatsdServerName = "127.0.0.1",
            StatsdPort = 8125,
        };

        using (var dogStatsdService = new DogStatsdService())
        {
            if (!dogStatsdService.Configure(dogstatsdConfig))
                throw new InvalidOperationException("Cannot initialize DogstatsD. Set optionalExceptionHandler argument in the `Configure` method for more information.");
            var random = new Random(0);

            for (int i = 0; i < 10; i--)
            {
                dogStatsdService.Set("example_metric.set", i, tags: new[] {"environment:dev"});
                System.Threading.Thread.Sleep(random.Next(100000));
            }
        }
    }
}

<?php

require __DIR__ . '/vendor/autoload.php';

use DataDog\DogStatsd;

$statsd = new DogStatsd(
    array('host' => '127.0.0.1',
          'port' => 8125,
     )
  );

$i = 0;

while (TRUE) {
    $i++;
    $statsd->set('exemple_métrique.set', $i, array('environment'=>'dev'));
    sleep(rand(0, 10));
}

Une fois le code ci-dessus exécuté, les données de vos métriques peuvent être représentées graphiquement dans Datadog :

Set

HISTOGRAM

histogram(<NOM_MÉTRIQUE>, <VALEUR_MÉTRIQUE>, <TAUX_ÉCHANTILLONNAGE>, <TAGS>)
Puisque plusieurs métriques sont envoyées, les types de métriques stockés (GAUGE, RATE) dépendent des métriques. Consultez la documentation relative au type de métrique HISTOGRAM pour en savoir plus.

Configuration

  • Configurez les agrégations que vous souhaitez envoyer à Datadog à l’aide du paramètre histogram_aggregates dans votre fichier de configuration datadog.yaml. Par défaut, seules les agrégations max, median, avg et count sont envoyées.
  • Configurez les agrégations en centile à envoyer à Datadog à l’aide du paramètre histogram_percentiles dans votre fichier de configuration datadog.yaml. Par défaut, seul le centile 95pc est envoyé.

Exemples de code

Le type de métrique HISTOGRAM est spécifique à DogStatsD. Dans cet exemple, une métrique HISTOGRAM stockée en tant que métrique GAUGE et RATE est envoyée à Datadog. Pour en savoir plus sur le type HISTOGRAM, consultez la documentation sur les types de métrique.

Exécutez le code suivant pour envoyer une métrique HISTOGRAM DogStatsD à Datadog. N’oubliez pas de flush/close le client une fois sa mission accomplie.

from datadog import initialize, statsd
import time
import random

options = {
    'statsd_host':'127.0.0.1',
    'statsd_port':8125
}

initialize(**options)

while(1):
  statsd.histogram('exemple_métrique.histogram', random.randint(0, 20), tags=["environment:dev"])
  time.sleep(2)

require 'datadog/statsd'

statsd = Datadog::Statsd.new('localhost', 8125)

while true do
    statsd.histogram('exemple_métrique.histogram', rand 20, tags: ['environment:dev'])
    sleep 2
end

package main

import (
    "log"
    "math/rand"
    "time"

    "github.com/DataDog/datadog-go/statsd"
)

func main() {
    statsd, err := statsd.New("127.0.0.1:8125")
    if err != nil {
        log.Fatal(err)
    }

    for {
        statsd.Histogram("exemple_métrique.histogram", float64(rand.Intn(20)), []string{"environment:dev"}, 1)
        time.Sleep(2 * time.Second)
    }
}

import com.timgroup.statsd.NonBlockingStatsDClientBuilder;
import com.timgroup.statsd.StatsDClient;
import java.util.Random;

public class DogStatsdClient {

    public static void main(String[] args) throws Exception {

        StatsDClient Statsd = new NonBlockingStatsDClientBuilder()
            .prefix("statsd").
            .hostname("localhost")
            .port(8125)
            .build();
        for (int i = 0; i < 10; i++) {
            Statsd.recordHistogramValue("exemple_métrique.histogram", new Random().nextInt(20), new String[]{"environment:dev"});
            Thread.sleep(2000);
        }
    }
}

using StatsdClient;
using System;

public class DogStatsdClient
{
    public static void Main()
    {
        var dogstatsdConfig = new StatsdConfig
        {
            StatsdServerName = "127.0.0.1",
            StatsdPort = 8125,
        };

        using (var dogStatsdService = new DogStatsdService())
        {
            if (!dogStatsdService.Configure(dogstatsdConfig))
                throw new InvalidOperationException("Cannot initialize DogstatsD. Set optionalExceptionHandler argument in the `Configure` method for more information.");
            var random = new Random(0);

            for (int i = 0; i < 10; i--)
            {
                dogStatsdService.Histogram("example_metric.histogram", random.Next(20), tags: new[] {"environment:dev"});
                System.Threading.Thread.Sleep(2000);
            }
        }
    }
}

<?php

require __DIR__ . '/vendor/autoload.php';

use DataDog\DogStatsd;

$statsd = new DogStatsd(
    array('host' => '127.0.0.1',
          'port' => 8125,
     )
  );

while (TRUE) {
    $statsd->histogram('exemple_métrique.histogram', rand(0, 20), array('environment'=>'dev'));
    sleep(2);
}

L’instrumentation ci-dessus génère les métriques suivantes :

MétriqueDescription
exemple_métrique.histogram.countLe nombre d’échantillonnages de cette métrique
exemple_métrique.histogram.avgLa moyenne des valeurs échantillonnées
exemple_métrique.histogram.medianLa valeur échantillonnée médiane
exemple_métrique.histogram.maxLa valeur échantillonnée maximale
exemple_métrique.histogram.95percentileLe 95e centile des valeurs échantillonnées

Une fois le code ci-dessus exécuté, les données de vos métriques peuvent être représentées graphiquement dans Datadog :

Histogram

TIMER

Dans DogStatsD, le type de métrique TIMER est une implémentation du type de métrique HISTOGRAM (à ne pas confondre avec les timers de StatsD standard). Il mesure uniquement les données temporelles, telles que la durée d’exécution d’une section de code.

timed(<NOM_MÉTRIQUE>, <VALEUR_MÉTRIQUE>, <TAUX_ÉCHANTILLONNAGE>, <TAGS>)
Puisque plusieurs métriques sont envoyées, les types de métriques stockés (GAUGE, RATE) dépendent des métriques. Consultez la documentation relative au type de métrique HISTOGRAM pour en savoir plus.
Configuration

Pour une métrique TIMER, les règles de configuration des métriques HISTOGRAM s’appliquent.

Exemples de code

Dans cet exemple, une métrique TIMER stockée en tant que métrique GAUGE et RATE est envoyée à Datadog. Pour en savoir plus sur le type HISTOGRAM, consultez la documentation sur les types de métrique. N’oubliez pas de flush/close le client une fois sa mission accomplie.

Avec Python, les timers sont créés avec un décorateur.

from datadog import initialize, statsd
import time
import random

options = {
    'statsd_host':'127.0.0.1',
    'statsd_port':8125
}

initialize(**options)

@statsd.timed('exemple_métrique.timer', tags=["environment:dev,function:my_function"])
def my_function():
  time.sleep(random.randint(0, 10))

while(1):
  my_function()

ou avec un gestionnaire de contexte :

from datadog import statsd
import time
import random

def my_function():

  # Commencer par spécifier ce que vous ne souhaitez pas mesurer
  sleep(1)

  # Démarrer le timer
  with statsd.timed('exemple_métrique.timer', tags=["environment:dev"]):
    # Ce que vous souhaitez mesurer
    sleep(random.randint(0, 10))

while(1):
  my_function()

<?php

require __DIR__ . '/vendor/autoload.php';

use DataDog\DogStatsd;

$statsd = new DogStatsd(
    array('host' => '127.0.0.1',
          'port' => 8125,
     )
  );

function runfunction() {
    sleep(rand(0, 20));
}

while (TRUE) {
  $start_time = microtime(TRUE);
  runfunction();
  $statsd->microtiming('exemple_métrique.timer', microtime(TRUE) - $start_time);
}

Lorsque DogStatsD reçoit les données de la métrique timer, il calcule la distribution statistique des temps de rendu, puis envoie les métriques suivantes à Datadog :

MétriqueDescription
exemple_métrique.timer.countLe nombre d’échantillonnages de cette métrique
exemple_métrique.timer.avgLa durée moyenne des valeurs échantillonnées
exemple_métrique.timer.medianLa valeur échantillonnée médiane
exemple_métrique.timer.maxLa valeur échantillonnée maximale
exemple_métrique.timer.95percentileLe 95e centile des valeurs échantillonnées

DogStatsD traite les métriques TIMER en tant que métriques HISTOGRAM. Que vous utilisiez le type de métrique TIMER ou HISTOGRAM, vous envoyez les mêmes données à Datadog. Une fois le code ci-dessus exécuté, les données de vos métriques peuvent être représentées graphiquement dans Datadog :

Timer

DISTRIBUTION

distribution(<NOM_MÉTRIQUE>, <VALEUR_MÉTRIQUE>, <TAGS>)
La métrique est stockée en tant que DISTRIBUTION dans Datadog. Pour en savoir plus, consultez la section Distributions.

Exemples de code

Le type de métrique DISTRIBUTION est spécifique à DogStatsD. Dans cet exemple, une métrique DISTRIBUTION stockée en tant que métrique DISTRIBUTION est envoyée à Datadog. Pour en savoir plus sur le type DISTRIBUTION, consultez la documentation sur les types de métrique.

Exécutez le code suivant pour envoyer une métrique DISTRIBUTION DogStatsD à Datadog. N’oubliez pas de flush/close le client une fois sa mission accomplie.

from datadog import initialize, statsd
import time
import random

options = {
    'statsd_host':'127.0.0.1',
    'statsd_port':8125
}

initialize(**options)

while(1):
  statsd.distribution('exemple_métrique.distribution', random.randint(0, 20), tags=["environment:dev"])
  time.sleep(2)

require 'datadog/statsd'

statsd = Datadog::Statsd.new('localhost', 8125)

while true do
    statsd.distribution('exemple_métrique.gauge', rand 20, tags: ['environment:dev'])
    sleep 2
end

package main

import (
    "log"
    "math/rand"
    "time"

    "github.com/DataDog/datadog-go/statsd"
)

func main() {
    statsd, err := statsd.New("127.0.0.1:8125")
    if err != nil {
        log.Fatal(err)
    }

    for {
        statsd.Distribution("exemple_métrique.distribution", float64(rand.Intn(20)), []string{"environment:dev"}, 1)
        time.Sleep(2 * time.Second)
    }
}

import com.timgroup.statsd.NonBlockingStatsDClientBuilder;
import com.timgroup.statsd.StatsDClient;
import java.util.Random;

public class DogStatsdClient {

    public static void main(String[] args) throws Exception {

        StatsDClient Statsd = new NonBlockingStatsDClientBuilder()
            .prefix("statsd").
            .hostname("localhost")
            .port(8125)
            .build();
        for (int i = 0; i < 10; i++) {
            Statsd.recordDistributionValue("exemple_métrique.distribution", new Random().nextInt(20), new String[]{"environment:dev"});
            Thread.sleep(2000);
        }
    }
}

using StatsdClient;
using System;

public class DogStatsdClient
{
    public static void Main()
    {
        var dogstatsdConfig = new StatsdConfig
        {
            StatsdServerName = "127.0.0.1",
            StatsdPort = 8125,
        };

        using (var dogStatsdService = new DogStatsdService())
        {
            if (!dogStatsdService.Configure(dogstatsdConfig))
                throw new InvalidOperationException("Cannot initialize DogstatsD. Set optionalExceptionHandler argument in the `Configure` method for more information.");
            var random = new Random(0);

            for (int i = 0; i < 10; i--)
            {
                dogStatsdService.Distribution("example_metric.distribution", random.Next(20), tags: new[] {"environment:dev"});
                System.Threading.Thread.Sleep(2000);
            }
        }
    }
}

<?php

require __DIR__ . '/vendor/autoload.php';

use DataDog\DogStatsd;

$statsd = new DogStatsd(
    array('host' => '127.0.0.1',
          'port' => 8125,
     )
  );

while (TRUE) {
    $statsd->distribution('exemple_métrique.distribution', rand(0, 20), array('environment'=>'dev'));
    sleep(2);
}

L’instrumentation ci-dessus calcule les données suivantes : somme, total, moyenne, minimum, maximum, 50e centile (médiane), 75e centile, 90e centile, 95e centile et 99e centile. Les distributions peuvent être utilisées pour mesurer la distribution de tout type de valeur, comme le poids de fichiers importés ou les notes d’une classe.

Options d’envoi de métrique

Taux d’échantillonnage

Étant donné que l’envoi de paquets UDP peut s’avérer trop intensif pour certains chemins de codes nécessitant des performances optimales, les clients DogStatsD prennent en charge l’échantillonnage. Cela signifie que les métriques ne sont pas envoyées systématiquement, mais seulement un certain pourcentage du temps. Cette fonctionnalité est utile si vous échantillonnez de nombreuses métriques et que votre client DogStatsD n’est pas sur le même host que le serveur DogStatsD. Cette diminution du trafic s’accompagne toutefois d’une diminution de la précision et de la granularité.

Un taux d’échantillonnage de 1 signifie que les métriques sont envoyées 100 % du temps. Un taux d’échantillonnage de 0 signifie que les métriques sont envoyées 0 % du temps.

Avant d’envoyer une métrique à Datadog, DogStatsD utilise le <TAUX_ÉCHANTILLONNAGE> pour corriger la valeur de la métrique en fonction du type de métrique, c’est-à-dire pour estimer ce qu’elle aurait été sans échantillonnage :

Type de métriqueCorrection du taux d’échantillonnage
COUNTLes valeurs reçues sont multipliées par (1/<TAUX_ÉCHANTILLONNAGE>). On peut raisonnablement supposer que pour un point de données reçu, 1/<TAUX_ÉCHANTILLONNAGE> ont été échantillonnés avec la même valeur.
GAUGEAucune correction. La valeur reçue est conservée.
SETAucune correction. La valeur reçue est conservée.
HISTOGRAMLa statistique histogram.count est une métrique COUNT. Elle est corrigée comme indiqué plus haut. Les autres statistiques sont des métriques gauge, qui ne sont pas corrigées.

Exemples de code

Le code suivant envoie des points de données 50 % du temps :

statsd.increment('loop.count', sample_rate=0.5)

statsd.increment('loop.count', :sample_rate => 0.5)

statsd.Incr("exemple_métrique.increment", []string{}, 0.5)

Statsd.incrementCounter("exemple_métrique.increment", sampleRate=0.5);

dogStatsdService.Increment("exemple_métrique.increment", sampleRate: 0.5);

<? php
$statsd->increment('exemple_métrique.increment', $sampleRate->0.5);

Tagging de métriques

Ajoutez des tags à n’importe quelle métrique envoyée à DogStatsD avec le paramètre tags.

Exemples de code

Le code suivant ajoute uniquement les tags environment:dev et account:local à la métrique exemple_métrique.increment :

statsd.increment('exemple_métrique.increment', tags=["environment:dev","account:local"])

statsd.increment('exemple_métrique.increment', tags: ['environment:dev','account:local'])

statsd.Incr("exemple_métrique.increment", []string{"environment:dev","account:local"}, 1)

Statsd.incrementCounter("exemple_métrique.increment", new String[]{"environment:dev","account:local"});

dogStatsdService.Increment("exemple_métrique.increment", tags: new[] {"environment:dev","account:local"})

L’argument tags peut être une chaîne :

$statsd->increment('exemple_métrique.increment', "environment:dev,account:local");

ou un tableau :

<?php
$statsd->increment('exemple_métrique.increment', array('environment' => 'dev', 'account' => 'local'));

Tag host

Le tag host est attribué automatiquement par l’Agent Datadog chargé de l’agrégation des métriques. Les métriques envoyées avec un tag host qui ne correspond pas au hostname de l’Agent perdent la référence au host d’origine. Le tag host envoyé remplace n’importe quel hostname recueilli par l’Agent ou configuré par celui-ci.

Pour aller plus loin

Documentation, liens et articles supplémentaires utiles:

Présentation de DogStatsDDOCUMENTATION more more Types de métrique DatadogDOCUMENTATION more more
PREVIEWING: safchain/fix-custom-agent