2

オープン テレメトリを使用して、次のアプリケーションのトレース情報をエクスポートしています。

  1. nodejs kafka プロデューサーは にメッセージを送信しますinput-topic。kafkajsインストルメント化されたライブラリを使用しopentelemetry-instrumentation-kafkajsます。AWS OTEL for NodeJS example の例を使用しています。これが私のものtracer.jsです：
module.exports = () => {
  diag.setLogger(new DiagConsoleLogger(), DiagLogLevel.ERROR);

  // create a provider for activating and tracking with AWS IdGenerator
  const attributes = {
      'service.name': 'nodejs-producer',
      'service.namespace': 'axel'
  }

  let resource = new Resource(attributes)

  const tracerConfig = {
    idGenerator: new AWSXRayIdGenerator(),
    plugins: {
        kafkajs: { enabled: false, path: 'opentelemetry-plugin-kafkajs' }
    },
    resource: resource
  };
  const tracerProvider = new NodeTracerProvider(tracerConfig);

  // add OTLP exporter
  const otlpExporter = new CollectorTraceExporter({
    url: (process.env.OTEL_EXPORTER_OTLP_ENDPOINT) ? process.env.OTEL_EXPORTER_OTLP_ENDPOINT : "localhost:55680"
  });
  tracerProvider.addSpanProcessor(new SimpleSpanProcessor(otlpExporter));
  tracerProvider.addSpanProcessor(new SimpleSpanProcessor(new ConsoleSpanExporter()));

  // Register the tracer with X-Ray propagator
  tracerProvider.register({
    propagator: new AWSXRayPropagator()
  });

  registerInstrumentations({
    tracerProvider,
    instrumentations: [new KafkaJsInstrumentation({})],
  });

  // Return a tracer instance
  return trace.getTracer("awsxray-tests");
}
  1. input-topicから読み取り、から生成するJava アプリケーションfinal-topic。また、AWS OTEL Java エージェントが装備されています。Java アプリは次のように起動します。
export OTEL_TRACES_EXPORTER=otlp
export OTEL_EXPORTER_OTLP_ENDPOINT=http://localhost:4317
export OTEL_PROPAGATORS=xray
export OTEL_RESOURCE_ATTRIBUTES="service.name=otlp-consumer-producer,service.namespace=axel"
export OTEL_METRICS_EXPORTER=none

java -javaagent:"${PWD}/aws-opentelemetry-agent.jar" -jar "${PWD}/target/otlp-consumer-producer.jar"
  1. otel/opentelemetry-collector-contribAWS XRay エクスポーターを使用しています。
receivers:
  otlp:
    protocols:
      grpc:
        endpoint: 0.0.0.0:4317

exporters:
  awsxray:
    region: 'eu-central-1'
    max_retries: 10

service:
  pipelines:
    traces:
      receivers: [otlp]
      exporters: [awsxray]

ログ メッセージと XRay コンソールから、トレースが公開されていることがわかります (正しい親トレース ID を使用)。NodeJS ログ メッセージ:

{
  traceId: '60d0c7d4cfc2d86b2df8624cb4bccead',
  parentId: undefined,
  name: 'input-topic',
  id: '3e289f00c4499ae8',
  kind: 3,
  timestamp: 1624295380734468,
  duration: 3787,
  attributes: {
    'messaging.system': 'kafka',
    'messaging.destination': 'input-topic',
    'messaging.destination_kind': 'topic'
  },
  status: { code: 0 },
  events: []
}

およびヘッダー付きの Java コンシューマー:

Headers([x-amzn-trace-id:Root=1-60d0c7d4-cfc2d86b2df8624cb4bccead;Parent=3e289f00c4499ae8;Sampled=1])

ご覧のとおり、親 ID とルート ID は互いに一致しています。ただし、サービス マップは切り離された方法で構築されます。 サービスマップ

正しいサービス マップをコンパイルするためにここで欠けている他の構成は何ですか?

4

0 に答える 0