Get raw span data from ClickHouse
(span_id: str)
| 413 | |
| 414 | |
| 415 | async def clickhouse_get_span_raw(span_id: str) -> dict: |
| 416 | """Get raw span data from ClickHouse""" |
| 417 | client = await get_async_clickhouse() |
| 418 | query = """ |
| 419 | SELECT * FROM {table_name} |
| 420 | WHERE SpanId = '{span_id}' |
| 421 | """ |
| 422 | query = query.format(table_name=IMPORT_TABLE_NAME, span_id=span_id) |
| 423 | result = await client.query(query) |
| 424 | if result and hasattr(result, 'result_rows') and len(result.result_rows) > 0: |
| 425 | row_dict = dict(zip(result.column_names, result.result_rows[0])) |
| 426 | return row_dict |
| 427 | |
| 428 | return None |
| 429 | |
| 430 | |
| 431 | async def clickhouse_create_span(span: Span) -> None: |
no test coverage detected
searching dependent graphs…