使用python驱动程序进行Cassandra跟踪读取

pip install cassandra-driver

from cassandra.cluster import Cluster
from cassandra.query import SimpleStatement
from cassandra.policies import RetryPolicy
from cassandra import ConsistencyLevel

# 连接到Cassandra集群
cluster = Cluster(["127.0.0.1"])  # 替换为你的Cassandra节点IP地址
session = cluster.connect("your_keyspace")  # 替换为你的键空间名称

# 启用跟踪
trace_id = session.execute("SELECT * FROM system.local WHERE key='local'", trace=True).info['tracing_id']

# 执行查询并启用跟踪
query = SimpleStatement("SELECT * FROM your_table", consistency_level=ConsistencyLevel.LOCAL_ONE)
result = session.execute(query, trace=True)

# 获取跟踪信息
trace_info = result.info['tracing_id']

# 打印跟踪信息
print(f"Trace ID: {trace_info}")

# 关闭连接
cluster.shutdown()

from cassandra.cluster import Cluster
from cassandra.query import SimpleStatement
from cassandra.policies import RetryPolicy
from cassandra import ConsistencyLevel
from cassandra.tracing import Tracing

# 连接到Cassandra集群
cluster = Cluster(["127.0.0.1"])  # 替换为你的Cassandra节点IP地址
session = cluster.connect("your_keyspace")  # 替换为你的键空间名称

# 启用跟踪并设置自定义跟踪回调
tracing = Tracing(session)
tracing.set_trace_callback(lambda trace_id, event: print(f"Trace ID: {trace_id}, Event: {event}"))

# 执行查询并启用跟踪
query = SimpleStatement("SELECT * FROM your_table", consistency_level=ConsistencyLevel.LOCAL_ONE)
result = session.execute(query, trace=True)

# 关闭连接
cluster.shutdown()