opentelemetry_cassandra_driver_instrumentation_quickstart.py

1from cassandra.cluster import Cluster
2from opentelemetry.instrumentation.cassandra import CassandraInstrumentor
3
4# Instrument the Cassandra driver
5CassandraInstrumentor().instrument()
6
7# Standard Cassandra driver usage
8cluster = Cluster(['127.0.0.1'])
9session = cluster.connect()
10
11# Queries executed through the session will now be automatically instrumented
12session.execute("CREATE KEYSPACE IF NOT EXISTS example WITH replication = {'class':'SimpleStrategy', 'replication_factor':1};")
13session.execute("USE example;")
14session.execute("CREATE TABLE IF NOT EXISTS users (id uuid PRIMARY KEY, name text);")
15
16# Example of an instrumented query
17session.execute("SELECT * FROM users")
18
19cluster.shutdown()