mirror of
https://github.com/BerriAI/litellm.git
synced 2026-10-10 03:28:53 +00:00
41df8cf4d0
* wip * feat(traces): establish shared Rust storage foundation * fix(traces): escape ClickHouse text parameters * test(traces): exercise response cap with bounded strings * fix(traces): remove unnecessary lint expectation * fix(traces): encode ClickHouse timestamp units in Rust * test(traces): mark exception match as a regex * refactor(traces): execute schema setup in Rust * refactor(traces): use shared logging execution wrapper * docs(traces): replace foundation README with boundary rules * fix(traces): use current bridge execution facade * fix(traces): account for protocol cast in lint budget Co-Authored-By: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com> --------- Co-authored-by: Devin AI <158243242+devin-ai-integration[bot]@users.noreply.github.com>
25 lines
1.2 KiB
SQL
25 lines
1.2 KiB
SQL
CREATE TABLE IF NOT EXISTS {database}.agent_traces
|
|
(
|
|
TeamId LowCardinality(String),
|
|
TraceId String,
|
|
StartTs SimpleAggregateFunction(min, DateTime64(9)),
|
|
EndTs SimpleAggregateFunction(max, DateTime64(9)),
|
|
ServiceName SimpleAggregateFunction(any, LowCardinality(String)),
|
|
RootName SimpleAggregateFunction(anyLast, String),
|
|
RootInput SimpleAggregateFunction(anyLast, String),
|
|
RootStatus SimpleAggregateFunction(anyLast, String),
|
|
SpanCount SimpleAggregateFunction(sum, UInt64),
|
|
AgentCount SimpleAggregateFunction(sum, UInt64),
|
|
LlmCount SimpleAggregateFunction(sum, UInt64),
|
|
ToolCount SimpleAggregateFunction(sum, UInt64),
|
|
ErrorCount SimpleAggregateFunction(sum, UInt64),
|
|
InputTokens SimpleAggregateFunction(sum, UInt64),
|
|
OutputTokens SimpleAggregateFunction(sum, UInt64),
|
|
Models SimpleAggregateFunction(groupUniqArrayArray, Array(String)),
|
|
AgentNames SimpleAggregateFunction(groupUniqArrayArray, Array(String)),
|
|
RequestIds SimpleAggregateFunction(groupArrayArray, Array(String))
|
|
)
|
|
ENGINE = AggregatingMergeTree
|
|
PARTITION BY toDate(StartTs)
|
|
ORDER BY (TeamId, TraceId)
|
|
TTL toDateTime(StartTs) + INTERVAL {trace_retention_days} DAY
|