Выберите и декодируйте большой двоичный объект с помощью драйвера python cassandra

Я пытаюсь запросить таблицу Cassandra traces, которая является частью архитектуры Jaeger. Как видите, поле refs представляет собой список:

cqlsh:jaeger_v1_dc1> describe traces

CREATE TABLE jaeger_v1_dc1.traces (
    trace_id blob,
    span_id bigint,
    span_hash bigint,
    duration bigint,
    flags int,
    logs list<frozen<log>>,
    operation_name text,
    parent_id bigint,
    process frozen<process>,
    refs list<frozen<span_ref>>,
    start_time bigint,
    tags list<frozen<keyvalue>>,
    PRIMARY KEY (trace_id, span_id, span_hash)
)

из кода питона:

traces = session.execute('SELECT span_id,refs from traces')

for t in traces:
    if t.refs is not None:
        parentTrace=t['refs'][0].trace_id
  1. Мой первый вопрос: можно ли напрямую выбрать родительскую трассировку без повторения результата? Есть ли способ получить первый элемент в списке, а затем получить элементы внутри из списка выбора?
  2. С терминала, использующего cqlsh, я получаю такой результат: trace_id: 0x00000000000000003917678c73006f57. Однако от клиента python cassandra я получил эту trace_id=b'\x00\x00\x00\x00\x00\x00\x00\x009\x17g\x8cs\x00oW' любую идею, какое преобразование с ней произошло? Как его расшифровать, так как я хочу снова запросить таблицу.

python-3.x cassandra jaeger cassandra-driver
person user1912404    schedule 08.11.2020    source источник

Ответы (1)


arrow_upward
2
arrow_downward

  1. Насколько мне известно, простого способа не существует, так как нет гарантии, что промежутки хранятся в определенном порядке. Однако стоит отметить, что если под parentTrace вы имеете в виду корневой диапазон трассировки (первый диапазон), то вы можете искать диапазоны, где refs равен null, потому что корневой диапазон не имеет родителя. Другой способ определить корневой диапазон — если trace_id == span_id.
  2. trace_id хранится как двоичный BLOB-объект. То, что вы видите в клиенте cassandra, представляет собой массив из 16 байтов, в котором каждый элемент октета представлен двумя шестнадцатеричными значениями. Чтобы преобразовать его в шестнадцатеричную строку, которую вы видите в cqlsh, вам нужно преобразовать весь массив в одну шестнадцатеричную строку. См. следующий пример Python, который делает это:
from cassandra.cluster import Cluster

cluster = Cluster(['127.0.0.1'])
session = cluster.connect()
rows = session.execute("select * from jaeger_v1_test.traces")
trace = rows[0]
hexstr = ''.join('{:02x}'.format(x) for x in trace.trace_id)
print("hex=%s, byte_arr=%s, len(byte_arr)=%d" % (hexstr, trace.trace_id, len(trace.trace_id)))
cluster.shutdown()
person albertteoh    schedule 08.11.2020
comment
query="SELECT * FROM traces where trace_id=0x"+hexstr Мне нужно было добавить начальный 0x, чтобы это работало - person user1912404; 09.11.2020