opentelemetry-instrumentation-pika

import pika from opentelemetry import trace from opentelemetry.sdk.resources import Resource from opentelemetry.sdk.trace import TracerProvider from opentelemetry.sdk.trace.export import ConsoleSpanExporter, SimpleSpanProcessor from opentelemetry.instrumentation.pika import PikaInstrumentor # Configure OpenTelemetry SDK resource = Resource.create({"service.name": "pika-test-app"}) provider = TracerProvider(resource=resource) processor = SimpleSpanProcessor(ConsoleSpanExporter()) provider.add_span_processor(processor) trace.set_tracer_provider(provider) # Instrument Pika PikaInstrumentor().instrument() # Pika usage (example: publish a message) def send_message(): print("Sending message...") connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) channel = connection.channel() channel.queue_declare(queue='hello') channel.basic_publish(exchange='', routing_key='hello', body=b'Hello World!') print("Message sent.") connection.close() if __name__ == "__main__": # Ensure RabbitMQ is running or adjust connection parameters try: send_message() print("Traces should be printed to the console.") except Exception as e: print(f"Error connecting to RabbitMQ or sending message: {e}") print("Please ensure RabbitMQ is running and accessible at 'localhost'.")