Apollo Federation 中的 OpenTelemetry

1
// Import required symbols
2
const { Resource } = require('@opentelemetry/resources');
3
const { SimpleSpanProcessor, ConsoleSpanExporter } = require ("@opentelemetry/sdk-trace-base");
4
const { NodeTracerProvider } = require("@opentelemetry/sdk-trace-node");
5
const { registerInstrumentations } = require('@opentelemetry/instrumentation');
6
const { HttpInstrumentation } = require ('@opentelemetry/instrumentation-http');
7
const { ExpressInstrumentation } = require ('@opentelemetry/instrumentation-express');
8
// DELETE IF SETTING UP A GATEWAY, UNCOMMENT OTHERWISE
9
// const { GraphQLInstrumentation } = require ('@opentelemetry/instrumentation-graphql');
10

11
// Register server-related instrumentation
12
registerInstrumentations({
13
  instrumentations: [
14
    new HttpInstrumentation(),
15
    new ExpressInstrumentation(),
16
    // DELETE IF SETTING UP A GATEWAY, UNCOMMENT OTHERWISE
17
    //new GraphQLInstrumentation()
18
  ]
19
});
20

21
// Initialize provider and identify this particular service
22
// (in this case, we're implementing a federated gateway)
23
const provider = new NodeTracerProvider({
24
  resource: Resource.default().merge(new Resource({
25
    // Replace with any string to identify this service in your system
26
    "service.name": "gateway",
27
  })),
28
});
29

30
// Configure a test exporter to print all traces to the console
31
const consoleExporter = new ConsoleSpanExporter();
32
provider.addSpanProcessor(
33
  new SimpleSpanProcessor(consoleExporter)
34
);
35

36
// Register the provider to begin tracing
37
provider.register();

1
npm install @opentelemetry/[email protected]

1
const { ZipkinExporter } = require("@opentelemetry/exporter-zipkin");

1
// Configure an exporter that pushes all traces to Zipkin
2
// (This assumes Zipkin is running on localhost at the 
3
// default port of 9411)
4
const zipkinExporter = new ZipkinExporter({
5
  // url: set_this_if_not_running_zipkin_locally
6
});
7
provider.addSpanProcessor(
8
  new SimpleSpanProcessor(zipkinExporter)
9
);

1
npm install @opentelemetry/[email protected]

1
const { OTLPTraceExporter } = require("@opentelemetry/exporter-trace-otlp-http");
2
const { BatchSpanProcessor } = require("@opentelemetry/sdk-trace-base");

1
// Configure an exporter that pushes all traces to a Collector
2
// (This assumes the Collector is running on the default url
3
// of https://127.0.0.1:4318/v1/traces)
4
const collectorTraceExporter = new OTLPTraceExporter();
5
provider.addSpanProcessor(
6
  new BatchSpanProcessor(collectorTraceExporter, {
7
    maxQueueSize: 1000,
8
    scheduledDelayMillis: 1000,
9
  }),
10
);