opentelemetry_psycopg2_instrumentation_quickstart_postgresql_tracing.py

1import psycopg2
2from opentelemetry.instrumentation.psycopg2 import Psycopg2Instrumentor
3
4# Optional: To instrument only specific connections, 
5# you can use Psycopg2Instrumentor().instrument_connection(cnx)
6# For global instrumentation:
7Psycopg2Instrumentor().instrument()
8
9# Now create a connection as usual
10cnx = psycopg2.connect(database="test", user="user", password="password", host="localhost", port="5432")
11cursor = cnx.cursor()
12cursor.execute("SELECT 1;")
13result = cursor.fetchone()
14cursor.close()
15cnx.close()