手動インスツルメンテーションを通して Data Streams Monitoring を設定する

このドキュメントは最新ではありません。最新版はこちらをクリックして英語版をご覧ください。
手動インスツルメンテーションは Java、Node.js、Python で利用可能です。

他の言語での手動インスツルメンテーションにご興味がある場合は、 support@datadoghq.com までお問い合わせください。

Data Streams Monitoring (DSM) はメッセージヘッダーを通じてコンテキストを伝播します。以下の場合、手動インスツルメンテーションを使用して DSM を設定してください。

  • DSM がサポートしていないメッセージキューテクノロジーを使用している場合
  • Kinesis などのヘッダーがないメッセージキューテクノロジーを使用している場合、または
  • Lambdas を使用している場合

手動インスツルメンテーションのインストール

  1. Datadog Agent v7.34.0 以降を使用していることを確認してください。

  2. メッセージを送信または受信するサービスで、サポートされているタイプを宣言します。例:

    kinesis、kafka、rabbitmq、sqs、sns

  3. 以下のサンプルコードのように、メッセージが生成されたときと消費されたときに Data Streams Monitoring のチェックポイントを呼び出します。

      import datadog.trace.api.experimental.*;
​​
Carrier headersAdapter = new Carrier(headers);
​
// データベース PUT を呼び出す前
DataStreamsCheckpointer.get().setProduceCheckpoint("<database-type>", "<topic-name>", headersAdapter);
​
// データベース GET を呼び出した後
DataStreamsCheckpointer.get().setConsumeCheckpoint("<database-type>", "<topic-name>", headersAdapter);

// ヘッダーを、コンテキストを渡すために使用しているものに置き換えてください
private class Carrier implements DataStreamsContextCarrier {
    private Headers headers;


    public Carrier(Headers headers) {
        this.headers = headers;
    }
​
    public Set<Entry<String, Object>> entries() {
        return this.headers.entrySet();
    }
​
    public void set(String key, String value){
        this.headers.put(key, value);
    }
}
      const tracer = require('dd-trace').init({})

// produce を呼び出す前
const headers = {}
tracer.dataStreamsCheckpointer.setProduceCheckpoint(
"<datastream-type>", "<queue-name>", headers
)

// consume を呼び出した後
tracer.dataStreamsCheckpointer.setConsumeCheckpoint(
"<datastream-type>", "<queue-name>", headers
)
      from ddtrace.data_streams import set_consume_checkpoint
from ddtrace.data_streams import set_produce_checkpoint

# before calling produce
headers = {}
set_produce_checkpoint(
"<datastream-type>", "<datastream-name>", headers.setdefault
)

# after calling consume
set_consume_checkpoint(
"<datastream-type>", "<datastream-name>", headers.get
)

    その他の参考資料

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

    Kafka インテグレーションドキュメント more more サービスカタログドキュメント more more