opentelemetry_pymysql_instrumentation_for_automatic_query_tracing.py

1import pymysql
2from opentelemetry.instrumentation.pymysql import PyMySQLInstrumentor
3
4# Optional: Trace providers and exporters would typically be initialized here
5# from opentelemetry import trace
6# from opentelemetry.sdk.trace import TracerProvider
7# trace.set_tracer_provider(TracerProvider())
8
9# Instrument pymysql
10PyMySQLInstrumentor().instrument()
11
12# Now use pymysql as usual
13cnx = pymysql.connect(database="MySQL_Database", user="user")
14cursor = cursor = cnx.cursor()
15cursor.execute("SELECT * FROM entries")
16
17for result in cursor:
18    print(result)
19
20cursor.close()
21cnx.close()