How to use Slonik with OpenTelemetry?

[gajus]

^

[gajus]

Here is an example of a simple interceptor that adds traceparent to queries:

import { context, defaultTextMapSetter } from '@opentelemetry/api';
import { W3CTraceContextPropagator } from '@opentelemetry/core';

// ...

interceptors.push({
  transformQuery: (queryContext, query) => {
    const propagator = new W3CTraceContextPropagator();

    const comments = {};

    propagator.inject(context.active(), comments, defaultTextMapSetter);

    if ('traceparent' in comments) {
      return {
        ...query,
        sql: `${query.sql} /* traceparent='${comments.traceparent}' */`,
      };
    }

    return query;
  },
});

Related question https://stackoverflow.com/questions/76831794/how-get-the-traceparent-in-opentelemetry

[gajus]

Turns out there is a simpler way. Simply pass addSqlCommenterCommentToQueries to PgInstrumentation.

import { PgInstrumentation } from '@opentelemetry/instrumentation-pg';

// ...

new PgInstrumentation({
  addSqlCommenterCommentToQueries: true,
}),