npm init -y
npm install undici \
@opentelemetry/instrumentation-undici \
@opentelemetry/sdk-node
npm install -D tsx # інструмент для безпосереднього запуску файлів TypeScript (.ts) за допомогою node
npm init -y
npm install undici \
@opentelemetry/instrumentation-undici \
@opentelemetry/sdk-node
/* client.ts */
import { NodeSDK } from '@opentelemetry/sdk-node';
import {
SimpleSpanProcessor,
ConsoleSpanExporter,
} from '@opentelemetry/sdk-trace-node';
import { UndiciInstrumentation } from '@opentelemetry/instrumentation-undici';
const sdk = new NodeSDK({
spanProcessors: [new SimpleSpanProcessor(new ConsoleSpanExporter())],
instrumentations: [new UndiciInstrumentation()],
});
sdk.start();
import { request } from 'undici';
request('http://localhost:8080/rolldice').then((response) => {
response.body.json().then((json: any) => console.log(json));
});
/* instrumentation.mjs */
import { NodeSDK } from '@opentelemetry/sdk-node';
import {
SimpleSpanProcessor,
ConsoleSpanExporter,
} from '@opentelemetry/sdk-trace-node';
import { UndiciInstrumentation } from '@opentelemetry/instrumentation-undici';
const sdk = new NodeSDK({
spanProcessors: [new SimpleSpanProcessor(new ConsoleSpanExporter())],
instrumentations: [new UndiciInstrumentation()],
});
sdk.start();
const { request } = require('undici');
request('http://localhost:8080/rolldice').then((response) => {
response.body.json().then((json) => console.log(json));
});
$ npx tsx --import ./instrumentation.ts app.ts
Listening for requests on http://localhost:8080
$ node --import ./instrumentation.mjs app.js
Listening for requests on http://localhost:8080
npx tsx client.ts
node client.js
// Сервіс, що відправляє
import { context, propagation, trace } from '@opentelemetry/api';
// Визначте інтерфейс для вихідного обʼєкта, який буде містити інформацію про трасування.
interface Carrier {
traceparent?: string;
tracestate?: string;
}
// Створіть вихідний обʼєкт, який відповідає цьому інтерфейсу.
const output: Carrier = {};
// Сереалізуйте traceparent та tracestate з контексту у
// вихідний обʼєкт.
//
// Цей приклад використовує активний контекст трасування, але ви можете
// використовувати будь-який контекст, який підходить для вашого сценарію.
propagation.inject(context.active(), output);
// Витягніть значення traceparent та tracestate з вихідного обʼєкта.
const { traceparent, tracestate } = output;
// Ви можете передати дані traceparent та tracestate
// через будь-який механізм, який ви використовуєте для пропагації
// між сервісами.
// Сервіс, що надсилає
const { context, propagation } = require('@opentelemetry/api');
const output = {};
// Сереалізуйте traceparent та tracestate з контексту у
// вихідний обʼєкт.
//
// Цей приклад використовує активний контекст трасування, але ви можете
// використовувати будь-який контекст, який підходить для вашого сценарію.
propagation.inject(context.active(), output);
const { traceparent, tracestate } = output;
// Ви можете передати дані traceparent та tracestate
// через будь-який механізм, який ви використовуєте для пропагації
// між сервісами.
// Сервіс, що приймає
import {
type Context,
propagation,
trace,
Span,
context,
} from '@opentelemetry/api';
// Визначте інтерфейс для вхідного обʼєкта, який включає 'traceparent' та 'tracestate'.
interface Carrier {
traceparent?: string;
tracestate?: string;
}
// Припустимо, що "input" є обʼєктом з ключами 'traceparent' та 'tracestate'.
const input: Carrier = {};
// Витягує дані 'traceparent' та 'tracestate' у контекстний обʼєкт.
//
// Ви можете потім вважати цей контекст активним для ваших
// трасувань.
let activeContext: Context = propagation.extract(context.active(), input);
let tracer = trace.getTracer('app-name');
let span: Span = tracer.startSpan(
spanName,
{
attributes: {},
},
activeContext,
);
// Встановіть створений спан як активний у десереалізованому контексті.
trace.setSpan(activeContext, span);
// Сервіс, що приймає
import { context, propagation, trace } from '@opentelemetry/api';
// Припустимо, що "input" є обʼєктом з ключами 'traceparent' та 'tracestate'
const input = {};
// Витягує дані 'traceparent' та 'tracestate' у контекстний обʼєкт.
//
// Ви можете потім вважати цей контекст активним для ваших
// трасувань.
let activeContext = propagation.extract(context.active(), input);
let tracer = trace.getTracer('app-name');
let span = tracer.startSpan(
spanName,
{
attributes: {},
},
activeContext,
);
// Встановіть створений спан як активний у десереалізованому контексті.
trace.setSpan(activeContext, span);