メトリクスの送信: DogStatsD

このドキュメントは最新ではありません。最新版はこちらをクリックして英語版をご覧ください。

StatsD がメトリクスのみを受け付けるのに対して、DogStatsD は、Datadog の主要な 3 種類のデータタイプ、すなわちメトリクス、イベント、サービスチェックをすべて受け付けます。ここでは、メトリクスの一般的な使用例をメトリクスタイプ別に分けて説明し、DogStatsD に特有のサンプリングレートとメトリクスのタグ付けオプションを紹介します。

COUNT、GAUGE、SET メトリクスタイプは、StatsD ユーザーにとって馴染みのあるものです。StatsD の TIMERは、DogStatsD の HISTOGRAM のサブセットです。さらに、DogStatsD を使用して HISTOGRAM および DISTRIBUTION メトリクスタイプを送信することができます。

注: 使用した送信方法により、Datadog 内に保存される実際のメトリクスタイプは送信メトリクスタイプと異なる場合があります。DogStatsD を通じて RATE メトリクスを取得するには、COUNT または HISTOGRAM メトリクスを送信してください。COUNT メトリクスの値と <HISTOGRAM>.count の値は、StatsD フラッシュ期間全体のメトリクス値の時間正規化された差分です。

##関数

DogStatsD をインストール すると、Datadog へメトリクスを送信する際、メトリクスタイプに応じて次の関数を使用できます。関数には、次の共有パラメーターがあります。

|パラメーター|型|必須|説明| ||||| | <METRIC_NAME> | String |はい|送信するメトリクスの名前。 | | <METRIC_VALUE> |Double |はい|メトリクスに関連付けられている値。 | | <SAMPLE_RATE> | Double | いいえ | メトリクスに適用するサンプルレート。0 (すべてがサンプリングされ、何も送信されない) から 1 (サンプルなし) までの値を取ります。詳細については、サンプルレートセクションを参照してください。| | <TAGS> | 文字列のリスト | いいえ | メトリクスに適用するタグのリスト。詳細については、メトリクスタグ付けセクションを参照してください。 | | <CARDINALITY> | Enum | いいえ | このメトリクスに割り当てるタグのカーディナリティ。 |

COUNT

increment(<METRIC_NAME>, <SAMPLE_RATE>, <TAGS>, <CARDINALITY> ) COUNT メトリクスをインクリメントするのに使用。Datadog に RATE タイプとして保存されます。時系列に保存される値は、StatsD フラッシュ期間全体のメトリクス値の時間正規化された差分です。

decrement(<METRIC_NAME>, <SAMPLE_RATE>, <TAGS>, <CARDINALITY>) COUNT メトリクスをデクリメントするのに使用。Datadog に RATE タイプとして保存されます。時系列に保存される値は、StatsD フラッシュ期間全体のメトリクス値の時間正規化された差分です。

count(<METRIC_NAME>, <METRIC_VALUE>, <SAMPLE_RATE>, <TAGS>, <CARDINALITY>) 任意の Value から COUNT メトリクスをインクリメントするのに使用。Datadog に RATE タイプとして保存されます。時系列に保存される値は、StatsD フラッシュ期間全体のメトリクス値の時間正規化された差分です。

注: COUNT タイプのメトリクスは、フラッシュ間隔で正規化され 1 秒あたりの単位数を報告するため、Datadog 内で小数を表示できます。

コード例

COUNT メトリクスを RATE メトリクスとして Datadog に送信します。COUNT タイプについては、メトリクスタイプ ドキュメントを参照してください。

次のコードを実行し、DogStatsD COUNT メトリクスを Datadog へ送信します。クライアントが不要になったら、忘れずに flush/close してください。

from datadog import initialize, statsd
import time

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

initialize(**options)

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

注: statsd.count は 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/v5/statsd"
)

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

		statsd.Incr("example_metric.increment", []string{"environment:dev"}, 1)
		statsd.Decr("example_metric.decrement", []string{"environment:dev"}, 1)
		statsd.Count("example_metric.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();
        while (true) {
            Statsd.incrementCounter("example_metric.increment", new String[]{"environment:dev"});
            Statsd.decrementCounter("example_metric.decrement", new String[]{"environment:dev"});
            Statsd.count("example_metric.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);

            while (true)
            {
                dogStatsdService.Increment("example_metric.increment", tags: new[] {"environment:dev"}, cardinality: Cardinality.Low);
                dogStatsdService.Decrement("example_metric.decrement", tags: new[] {"environment:dev"}, cardinality: Cardinality.High);
                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('example_metric.increment', 1, array('environment'=>'dev'), 'low');
    $statsd->decrement('example_metric.decrement', 1, array('environment'=>'dev'), 'high');
    sleep(10);
}

const tracer = require('dd-trace');
tracer.init();

tracer.dogstatsd.increment('example_metric.increment', 1, { environment: 'dev' });
tracer.dogstatsd.decrement('example_metric.decrement', 1, { environment: 'dev' });

上のコードを実行すると、メトリクスデータを Datadog でグラフ化できます。

インクリメントとデクリメント

値が COUNT として送信されるため、Datadog では RATE として保存されます。Datadog で未加工のカウントを取得するには、累積合計 や 積分 などの関数を系列に適用します。

累積合計でのインクリメントとデクリメント

GAUGE

gauge(<METRIC_NAME>, <METRIC_VALUE>, <SAMPLE_RATE>, <TAGS>, <CARDINALITY>) Datadog に GAUGE タイプとして保存されます。時系列に保存される値は、StatsD フラッシュ期間の間にメトリクスに送信された最後のゲージ値です。

コード例

GAUGE メトリクスを GAUGE メトリクスとしてDatadog に送信します。GAUGE タイプについては、メトリクスタイプ ドキュメントを参照してください。

次のコードを実行し、DogStatsD GAUGE メトリクスを Datadog へ送信。クライアントが不要になったら、忘れずに flush/close してください。

注: メトリクスの送信呼び出しは非同期です。メトリクスを確実に送信したい場合は、プログラムが終了する前に flush を呼び出してください。

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('example_metric.gauge', i, tags=["environment:dev"], cardinality="low")
  time.sleep(10)

require 'datadog/statsd'

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

i = 0

while true do
    i += 1
    statsd.gauge('example_metric.gauge', i, tags: ['environment:dev'], cardinality: 'low')
    sleep 10
end

package main

import (
	"log"
	"time"

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

func main() {
	statsd, err := statsd.New("127.0.0.1:8125")
	if err != nil {
		log.Fatal(err)
	}
	var i float64
	for true {
		i += 1
		statsd.Gauge("example_metric.gauge", i, []string{"environment:dev"}, 1, CardinalityHigh)
		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; true; i++) {
            Statsd.recordGaugeValue("example_metric.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; true; i++)
            {
                dogStatsdService.Gauge("example_metric.gauge", i, tags: new[] {"environment:dev"}, cardinality: Cardinality.High);
                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('example_metric.gauge', $i, array('environment'=>'dev'), 'low');
    sleep(10);
}

const tracer = require('dd-trace');
tracer.init();

let i = 0;
while(true) {
  i++;
  tracer.dogstatsd.gauge('example_metric.gauge', i, { environment: 'dev' });
}

上のコードを実行すると、メトリクスデータを Datadog でグラフ化できます。

Gauge

SET

set(<METRIC_NAME>, <METRIC_VALUE>, <SAMPLE_RATE>, <TAGS>, <CARDINALITY>) Datadog に GAUGE タイプとして保存されます。時系列に保存される値は、フラッシュ期間の間に StatsD に送信されたメトリクスの一意の値のカウントです。

コード例

SET メトリクスを GAUGE メトリクスとして Datadog に送信します。

次のコードを実行し、DogStatsD SET メトリクスを Datadog へ送信。クライアントが不要になったら、忘れずに flush/close してください。

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('example_metric.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('example_metric.gauge', i, tags: ['environment:dev'])
    sleep rand 10
end

package main

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

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

func main() {
	statsd, err := statsd.New("127.0.0.1:8125")
	if err != nil {
		log.Fatal(err)
	}
	var i float64
	for true {
		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; true; 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; true; 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('example_metric.set', $i, 1, array('environment'=>'dev'), 'low');
    sleep(rand(0, 10));
}

上のコードを実行すると、メトリクスデータを Datadog でグラフ化できます。

Set

HISTOGRAM

histogram(<METRIC_NAME>, <METRIC_VALUE>, <SAMPLE_RATE>, <TAGS>, <CARDINALITY>) 複数のメトリクスが送信されるため、保存されるメトリクスタイプ (GAUGE、RATE) はメトリクスに依存します。詳細については、HISTOGRAM メトリクスタイプ のドキュメントを参照してください。

構成

  • Datadog に送信する集計を、datadog.yaml 構成ファイル の histogram_aggregates パラメーターで構成します。デフォルトでは、max、median、avg、count の各集計のみが送信されます。
  • Datadog に送信するパーセンタイル集計を、datadog.yaml 構成ファイル の histogram_percentiles パラメーターで構成します。デフォルトでは、95pc のパーセンタイルのみが送信されます。

コード例

HISTOGRAM メトリクスタイプは DogStatsD に特有です。GAUGE および RATE メトリクスとして保存された HISTOGRAM メトリクスを Datadog に送信します。HISTOGRAM タイプについては、メトリクスタイプ ドキュメントを参照してください。

次のコードを実行し、DogStatsD HISTOGRAM メトリクスを Datadog へ送信。クライアントが不要になったら、忘れずに flush/close してください。

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('example_metric.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('example_metric.histogram', rand 20, tags: ['environment:dev'])
    sleep 2
end

package main

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

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

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

	for true {
		statsd.Histogram("example_metric.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();
        while (true) {
            Statsd.recordHistogramValue("example_metric.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);

            while (true)
            {
                dogStatsdService.Histogram("example_metric.histogram", random.Next(20), tags: new[] {"environment:dev"}, Cardinality: Cardinality.High);
                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('example_metric.histogram', rand(0, 20), 1, array('environment'=>'dev'), 'low');
    sleep(2);
}

上のインスツルメンテーションは、次のメトリクスを生成します。

| メトリクス | 説明 | ||| | example_metric.histogram.count | このメトリクスがサンプリングされた回数 | | example_metric.histogram.avg | サンプリングされた値の平均 | | example_metric.histogram.median | サンプリングされた値の中央値 | | example_metric.histogram.max | サンプリングされた値の最大値 | | example_metric.histogram.95percentile | サンプリングされた値の 95 パーセンタイル |

上のコードを実行すると、メトリクスデータを Datadog でグラフ化できます。

ヒストグラム

TIMER

DogStatsD の TIMER メトリクスタイプは、HISTOGRAM メトリクスタイプの実装です (標準の StatsD のタイマーと混同しないでください)。これは、タイミングデータのみを測定します。たとえば、コードのセクションが実行されるのにかかる時間です。

timed(<METRIC_NAME>, <METRIC_VALUE>, <SAMPLE_RATE>, <TAGS>, <CARDINALITY>) 複数のメトリクスが送信されるため、保存されるメトリクスタイプ (GAUGE、RATE) はメトリクスに依存します。詳細については、HISTOGRAM メトリクスタイプ のドキュメントを参照してください。

構成

TIMER には、HISTOGRAM コンフィギュレーションルールが適用されます。

コード例

GAUGE および RATE メトリクスとして保存された TIMER メトリクスを Datadog に送信します。HISTOGRAM タイプについては、メトリクスタイプ ドキュメントを参照してください。クライアントが不要になったら、忘れずに flush/close してください。

Python では、タイマーはデコレータで作成されます。

from datadog import initialize, statsd
import time
import random

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

initialize(**options)

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

while(1):
  my_function()

または、コンテキストマネージャーを使用します。

from datadog import statsd
import time
import random

def my_function():

  # First some stuff you don't want to time
  sleep(1)

  # Now start the timer
  with statsd.timed('example_metric.timer', tags=["environment:dev"]):
    # do something to be measured
    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('example_metric.timer', microtime(TRUE) - $start_time);
}

DogStatsD はタイマーメトリクスデータを受け取ると、レンダリング時間の統計的分布を計算し、次のメトリクスを Datadog に送信します。

| メトリクス | 説明 | ||| | example_metric.timer.count | このメトリクスがサンプリングされた回数 | | example_metric.timer.avg | サンプリングされた値の平均時間 | | example_metric.timer.median | サンプリングされた値の中央値 | | example_metric.timer.max | サンプリングされた値の最大値 | | example_metric.timer.95percentile | サンプリングされた値の 95 パーセンタイル |

DogStatsD は、TIMER を HISTOGRAM メトリクスとして扱います。TIMER と HISTOGRAM のどちらのメトリクスタイプを使用しても、Datadog に送信されるデータは同じです。上のコードを実行すると、メトリクスデータを Datadog でグラフ化できます。

タイマー

DISTRIBUTION

distribution(<METRIC_NAME>, <METRIC_VALUE>, <TAGS>, <CARDINALITY>) Datadog で DISTRIBUTION タイプとして保存。詳細については、専用の Distribution に関するドキュメント を参照してください。

コード例

DISTRIBUTION メトリクスタイプは DogStatsD に特有です。DISTRIBUTION メトリクスとして保存された DISTRIBUTION メトリクスを Datadog に送信します。DISTRIBUTION タイプについては、メトリクスタイプ ドキュメントを参照してください。

次のコードを実行し、DogStatsD DISTRIBUTION メトリクスを Datadog へ送信。クライアントが不要になったら、忘れずに flush/close してください。

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('example_metric.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('example_metric.distribution', rand 20, tags: ['environment:dev'])
    sleep 2
end

package main

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

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

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

	for true {
		statsd.Distribution("example_metric.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();
        while (true) {
            Statsd.recordDistributionValue("example_metric.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);

            while (true)
            {
                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('example_metric.distribution', rand(0, 20), 1, array('environment'=>'dev'), 'high');
    sleep(2);
}

const tracer = require('dd-trace');
tracer.init();

while(true) {
  tracer.dogstatsd.distribution('example_metric.distribution', Math.random() * 20, { environment: 'dev' });
  await new Promise(r => setTimeout(r, 2000));
}

上記のインスツルメンテーションでは、sum、count、average、minimum、maximum、50th percentile (中央値)、75th percentile、90th percentile、95th percentile、99th percentile を計算します。ディストリビューションは、アップロードされたファイルのサイズ、教室でのテストの得点など、あらゆる種類の値の分布の測定に使用できます。

メトリクスの送信オプション

サンプリングレート

高パフォーマンスを必要とするコードパスにとっては、UDP パケットを送信する際のオーバーヘッドが大きすぎる可能性があるため、DogStatsD クライアントはサンプリングをサポートしています (メトリクスを一定の割合でのみ送信します)。多くのメトリクスをサンプリングする場合や、DogStatsD クライアントが DogStatsD サーバーと同じホストにない場合に便利です。トラフィックが減少しますが、精度と粒度が失われるという二律背反が生じます。

サンプリングレート 1 は 100% の時間メトリクスを送信し、サンプリングレート 0 は 0% の時間メトリクスを送信します。

DogStatsD は Datadog にメトリクスを送信する前に、<SAMPLE_RATE> を使用し、メトリクスタイプに応じてメトリクス値を補正します (サンプリングなしで値を推定するため)。

| メトリクスタイプ | サンプリングレート補正 | ||| | COUNT | 受け取った値は (1/<SAMPLE_RATE>) 倍として計上されます。受信したデータポイント 1 つに対し、1/<SAMPLE_RATE> 値が同じ値で実際にサンプリングされたと考えるのは理にかなっています。| | GAUGE | 補正なし。受信した値はそのまま残ります。 | | SET | 補正なし。受信した値はそのまま残ります。 | | HISTOGRAM | histogram.count 統計は COUNT メトリクスであり、上記の補正を受け取ります。他の統計は GAUGE メトリクスなので、「補正」は行われません。 | | DISTRIBUTION | 受信した値は、1/<SAMPLE_RATE> 回としてカウントされます。受信したデータポイント 1 つに対し、1/<SAMPLE_RATE> 値が同じ値で実際にサンプリングされたと考えるのは理にかなっています。|

コード例

次のコードは、半分の時間だけポイントを送信します。

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

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

statsd.Incr("example_metric.increment", []string{}, 0.5)

Statsd.incrementCounter("example_metric.increment", sampleRate=0.5);

dogStatsdService.Increment("example_metric.increment", sampleRate: 0.5);

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

メトリクスのタグ付け

tags パラメーターを使用して、DogStatsD へ送るメトリクスにタグを追加します。

コード例

次のコードは、environment:dev および account:local タグのみを example_metric.increment メトリクスに追加します。

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

statsd.increment('example_metric.increment', tags: ['environment:dev','account:local'])

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

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

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

tags 引数は文字列にすることができます。

$statsd->increment('example_metric.increment', 1.0, "environment:dev,account:local");

または配列にすることができます。

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

tracer.dogstatsd.increment('example_metric.increment', 1, { environment: 'dev', account: 'local' });

ホストタグ

ホストタグは、メトリクスを集約する Datadog Agent によって自動的に割り当てられます。ホストタグが Agent のホスト名と一致しないメトリクスは、元のホストへの参照を失います。送信されたホストタグにより、Agent で収集または設定されたホスト名がオーバーライドされます。

参考資料

お役に立つドキュメント、リンクや記事:

DogStatsD 入門DOCUMENTATION more more Datadog メトリクスタイプDOCUMENTATION more more