OpenTelemetry Python으로 마이그레이션

pip install aws-xray-sdk
        

pip install opentelemetry-api opentelemetry-sdk opentelemetry-exporter-otlp opentelemetry-propagator-aws-xray
        

X-Ray에서는 전역xray_recorder이 초기화되고 이를 사용하여 세그먼트 및 하위 세그먼트를 생성합니다.

OpenTelemetry에서는 글로벌를 초기화해야 합니다TracerProvider. 이를 사용하면 애플리케이션의 모든 위치에서 스팬을 생성하는 데 사용할 수 있는 추적기를 얻을 TracerProvider수 있습니다. 다음 구성 요소를 구성하는 것이 좋습니다.

from opentelemetry import (
    trace,
    propagate
)
from opentelemetry.sdk.trace import TracerProvider

from opentelemetry import trace
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.exporter.otlp.proto.http.trace_exporter import OTLPSpanExporter
from opentelemetry.sdk.trace.export import BatchSpanProcessor
from opentelemetry.propagators.aws import AwsXRayPropagator

# Sends generated traces in the OTLP format to an OTel Collector running on port 4318
otlp_exporter = OTLPSpanExporter(endpoint="http://localhost:4318/v1/traces")
# Processes traces in batches as opposed to immediately one after the other
span_processor = BatchSpanProcessor(otlp_exporter)
# More configurations can be done here. We will visit them later.

# Sets the global default tracer provider
provider = TracerProvider(active_span_processor=span_processor)
trace.set_tracer_provider(provider)

# Configures the global propagator to use the X-Ray Propagator
propagate.set_global_textmap(AwsXRayPropagator())

# Creates a tracer from the global tracer provider
tracer = trace.get_tracer("my.tracer.name")
# Use this tracer to create Spans
          

X-Ray Python SDK는 Django, Flask 및 Bottle과 같은 애플리케이션 프레임워크를 지원하여 실행 중인 Python 애플리케이션에 대한 수신 요청을 추적합니다. 이는 각 프레임워크의 애플리케이션에 XRayMiddleware를 추가하여 수행됩니다.

OpenTelemetry는 특정 계측 라이브러리를 통해 Django 및 Flask에 대한 계측을 제공합니다. OpenTelemetry에서 사용할 수 있는 Bottle에 대한 계측은 없으며 OpenTelemetry WSGI 계측 을 사용하여 애플리케이션을 추적할 수 있습니다.

다음 코드 예제의 경우 다음 종속성이 필요합니다.

pip install opentelemetry-instrumentation-flask
        

애플리케이션 프레임워크에 계측을 추가하기 전에 OpenTelemetry SDK를 초기화하고 글로벌 TracerProvider를 등록해야 합니다. 그렇지 않으면 추적 작업은가 됩니다no-ops. 글로벌를 구성한 후에는 애플리케이션 프레임워크에 계측기를 사용할 TracerProvider수 있습니다. 다음 예제에서는 Flask 애플리케이션을 보여줍니다.

from flask import Flask
from opentelemetry import trace
from opentelemetry.instrumentation.flask import FlaskInstrumentor
from opentelemetry.sdk.extension.aws.resource import AwsEc2ResourceDetector
from opentelemetry.sdk.resources import get_aggregated_resources
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import BatchSpanProcessor, ConsoleSpanExporter

provider = TracerProvider(resource=get_aggregated_resources(
    [
        AwsEc2ResourceDetector(),
    ]))

processor = BatchSpanProcessor(ConsoleSpanExporter())
provider.add_span_processor(processor)
trace.set_tracer_provider(provider)

# Creates a tracer from the global tracer provider
tracer = trace.get_tracer("my.tracer.name")

app = Flask(__name__)

# Instrument the Flask app
FlaskInstrumentor().instrument_app(app)


@app.route('/')
def hello_world():
    return 'Hello World!'


if __name__ == '__main__':
    app.run()
        

X-Ray Python SDK는 botocore 라이브러리를 패치하여 AWS SDK 클라이언트 요청을 추적합니다. 자세한 내용은 Python용 X-Ray AWS SDK를 사용하여 SDK 호출 추적을 참조하세요. 애플리케이션에서 patch_all() 메서드는를 사용하여 또는 라이브러리를 사용하여 모든 boto3라이브러리 botocore 또는 패치를 선택적으로 계측하는 데 사용됩니다patch((['botocore'])). 선택한 메서드는 애플리케이션의 모든 Boto3 클라이언트를 계측하고 이러한 클라이언트를 사용하여 이루어진 모든 호출에 대해 하위 세그먼트를 생성합니다.

다음 코드 예제의 경우 다음 종속성이 필요합니다.

pip install opentelemetry-instrumentation-botocore
        

프로그래밍 방식으로 OpenTelemetry Botocore 계측을 사용하여 애플리케이션의 모든 Boto3 클라이언트를 계측합니다. 다음 예제에서는 botocore 계측을 보여줍니다.

import boto3
import opentelemetry.trace as trace
from botocore.exceptions import ClientError
from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.resources import get_aggregated_resources
from opentelemetry.sdk.trace.export import (
    BatchSpanProcessor,
    ConsoleSpanExporter,
)
from opentelemetry.instrumentation.botocore import BotocoreInstrumentor

provider = TracerProvider()
processor = BatchSpanProcessor(ConsoleSpanExporter())
provider.add_span_processor(processor)
trace.set_tracer_provider(provider)

# Creates a tracer from the global tracer provider
tracer = trace.get_tracer("my.tracer.name")

# Instrument BotoCore
BotocoreInstrumentor().instrument()

# Initialize S3 client
s3 = boto3.client("s3", region_name="us-east-1")

# Your bucket name
bucket_name = "my-example-bucket"

# Get bucket location (as an example of describing it)
try:
    response = s3.get_bucket_location(Bucket=bucket_name)
    region = response.get("LocationConstraint") or "us-east-1"
    print(f"Bucket '{bucket_name}' is in region: {region}")

    # Optionally, get bucket's creation date via list_buckets
    buckets = s3.list_buckets()
    for bucket in buckets["Buckets"]:
        if bucket["Name"] == bucket_name:
            print(f"Bucket created on: {bucket['CreationDate']}")
            break
except ClientError as e:
    print(f"Failed to describe bucket: {e}")
        

X-Ray Python SDK는 요청 라이브러리를 패치하여 요청을 통해 발신 HTTP 호출을 추적합니다. 자세한 내용은 Python용 X-Ray SDK를 사용하여 다운스트림 HTTP 웹 서비스에 대한 호출 추적을 참조하세요. 애플리케이션에서 patch_all() 메서드를 사용하여 모든 라이브러리를 계측하거나를 사용하여 요청 라이브러리를 선택적으로 패치할 수 있습니다patch((['requests'])). 모든 옵션은 requests 라이브러리를 계측하여를 통해 이루어진 모든 호출에 대해 하위 세그먼트를 생성합니다requests.

다음 코드 예제의 경우 다음 종속성이 필요합니다.

pip install opentelemetry-instrumentation-requests
        

프로그래밍 방식으로 OpenTelemetry Requests Instrumentation을 사용하여 요청 라이브러리를 계측하여 애플리케이션에서 수행한 HTTP 요청에 대한 트레이스를 생성합니다. 자세한 내용은 OpenTelemetry 요청 계측을 참조하세요. 다음 예제에서는 requests 라이브러리 계측을 보여줍니다.

from opentelemetry.instrumentation.requests import RequestsInstrumentor

# Instrument Requests
RequestsInstrumentor().instrument()

...

    example_session = requests.Session()
    example_session.get(url="https://example.com")
        

또는 기본 urllib3 라이브러리를 계측하여 HTTP 요청을 추적할 수도 있습니다.

# pip install opentelemetry-instrumentation-urllib3
from opentelemetry.instrumentation.urllib3 import URLLib3Instrumentor

# Instrument urllib3
URLLib3Instrumentor().instrument()

...

    example_session = requests.Session()
    example_session.get(url="https://example.com")