OpenTelemetry Elasticsearch Instrumentation for Node.js

This module provides automatic instrumentation for @elastic/elasticsearch and follows otel DB Semantic Conventions.

Installation

npm install opentelemetry-instrumentation-elasticsearch

Usage

For further automatic instrumentation instruction see the @opentelemetry/instrumentation package.

const { NodeTracerProvider } = require('@opentelemetry/sdk-trace-node');
const { registerInstrumentations } = require('@opentelemetry/instrumentation');
const { ElasticsearchInstrumentation } = require('opentelemetry-instrumentation-elasticsearch');

registerInstrumentations({
  tracerProvider,
  instrumentations: [
    new ElasticsearchInstrumentation({
      // Config example (all optional)
      suppressInternalInstrumentation: false,
      moduleVersionAttributeName: 'elasticsearchClient.version',
      responseHook: (span, result) => {
        span.setAttribute('db.response', JSON.stringify(result));
      },
      dbStatementSerializer: (operation, params, options) => {
        return JSON.stringify(params);
      }
    })
  ]
});

Elasticsearch Instrumentation Options

Elasticsearch instrumentation has few options available to choose from. You can set the following (all optional):

| Options | Type | Default | Description | | --- | --- | --- | --- | | suppressInternalInstrumentation | boolean | false | Elasticsearch operation use http/https under the hood. Setting this to true will hide the underlying request spans (if instrumented). | | responseHook | ResponseHook (function) | undefined | Hook called before response is returned, which allows to add custom attributes to span.Function receive params: spanresult (object) | | dbStatementSerializer | DbStatementSerializer (function) | JSON.stringify({params, options}) | Elasticsearch instrumentation will serialize db.statement using this function response.Function receive params: operation (string)params (object)options (object)Function response must be a string | moduleVersionAttributeName | string | undefined | If passed, a span attribute will be added to all spans with key of the provided moduleVersionAttributeName and value of the @elastic/elasticsearch version |

Please make sure dbStatementSerializer is error proof, as errors are not handled while executing this function.

db.operation attribute

db.operation contain the API function called. For the full list see API reference.

Few examples:

• client.bulk
• client.search
• client.index
• cat.shards
• cluster.health

This extension (and many others) was developed by Aspecto with ❤️