Python — AWS Lambda

receivers:
  telemetryapi:

  otlp:
    protocols:
      grpc:
      http:

exporters:
  otlp_http/trace0:
    endpoint: https://app.trace0hq.com/api
    headers:
      X-API-KEY: 'YOUR_TRACE0_ENV_API_KEY'

processors:
  batch:

  decouple:

  resource:
    attributes:
      - key: service.name
        value: "${env:OTEL_SERVICE_NAME}"
        action: upsert

service:
  pipelines:
    traces:
      receivers: [otlp]
      processors: [resource, batch, decouple]
      exporters: [otlp_http/trace0]

    metrics:
      receivers: [otlp]
      processors: [resource, batch, decouple]
      exporters: [otlp_http/trace0]

    logs:
      receivers: [telemetryapi]
      processors: [resource, batch, decouple]
      exporters: [otlp_http/trace0]

  import logging
  from opentelemetry import trace

  class TraceContextFilter(logging.Filter):
      def filter(self, record):
          ctx = trace.get_current_span().get_span_context()
          if ctx.is_valid:
              record.trace_id = format(ctx.trace_id, '032x')
              record.span_id = format(ctx.span_id, '016x')
          return True

from opentelemetry import trace
from opentelemetry.trace import StatusCode

def handler(event, context):
  http_method = event.get('httpMethod', '')
  path = event.get('path', '')

  # Set the http request method and route on the parent span.
  span = trace.get_current_span()
  span.set_attributes({
      'http.request.method': http_method,
      'http.route': path,
  })

  try:
      result = process_event(event)

      # Set the HTTP response code and mark the parent span as failed for 4xx/5xx responses.
      status_code = result['statusCode']
      span.set_attribute('http.response.status_code', status_code)
      span.set_status(StatusCode.OK if status_code < 400 else StatusCode.ERROR)

      return result

  except Exception as e:
      # Set the exception, HTTP error code and status on the parent span.
      span.record_exception(e)
      span.set_attribute('http.response.status_code', 500)
      span.set_status(StatusCode.ERROR)
      return {
          'statusCode': 500,
          'headers': {'Content-Type': 'application/json'},
          'body': json.dumps({'error': 'Internal server error'}),
      }