External/signoz
1
0
Fork 0
mirror of https://github.com/SigNoz/signoz.git synced 2025-12-18 07:56:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: use correct column names (#8659)

Browse Source
This commit is contained in:
Nityananda Gohain 2025-07-30 10:32:58 +05:30 committed by GitHub
parent 3d80a03f8a
commit 8e9a1b34cb
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/query-service/app/clickhouseReader/reader.go
View File

@ -272,7 +272,7 @@ func (r *ClickHouseReader) GetQueryRangeResult(ctx context.Context, query *model
func (r *ClickHouseReader) GetServicesList(ctx context.Context) (*[]string, error) { func (r *ClickHouseReader) GetServicesList(ctx context.Context) (*[]string, error) {
services := []string{} services := []string{}
rows, err := r.db.Query(ctx, fmt.Sprintf(`SELECT DISTINCT serviceName FROM %s.%s WHERE ts_bucket_start > (toUnixTimestamp(now() - INTERVAL 1 DAY) - 1800) AND toDate(timestamp) > now() - INTERVAL 1 DAY`, r.TraceDB, r.traceTableName)) rows, err := r.db.Query(ctx, fmt.Sprintf(`SELECT DISTINCT resource_string_service$$name FROM %s.%s WHERE ts_bucket_start > (toUnixTimestamp(now() - INTERVAL 1 DAY) - 1800) AND toDate(timestamp) > now() - INTERVAL 1 DAY`, r.TraceDB, r.traceTableName))
if err != nil { if err != nil {
return nil, fmt.Errorf("error in processing sql query") return nil, fmt.Errorf("error in processing sql query")
} }
@ -426,18 +426,18 @@ func (r *ClickHouseReader) GetServices(ctx context.Context, queryParams *model.G
query := fmt.Sprintf( query := fmt.Sprintf(
`SELECT `SELECT
quantile(0.99)(durationNano) as p99, quantile(0.99)(duration_nano) as p99,
avg(durationNano) as avgDuration, avg(duration_nano) as avgDuration,
count(*) as numCalls count(*) as numCalls
FROM %s.%s FROM %s.%s
WHERE serviceName = @serviceName AND name In @names AND timestamp>= @start AND timestamp<= @end`, WHERE resource_string_service$$name = @serviceName AND name In @names AND timestamp>= @start AND timestamp<= @end`,
r.TraceDB, r.traceTableName, r.TraceDB, r.traceTableName,
) )
errorQuery := fmt.Sprintf( errorQuery := fmt.Sprintf(
`SELECT `SELECT
count(*) as numErrors count(*) as numErrors
FROM %s.%s FROM %s.%s
WHERE serviceName = @serviceName AND name In @names AND timestamp>= @start AND timestamp<= @end AND statusCode=2`, WHERE resource_string_service$$name = @serviceName AND name In @names AND timestamp>= @start AND timestamp<= @end AND statusCode=2`,
r.TraceDB, r.traceTableName, r.TraceDB, r.traceTableName,
) )
@ -757,10 +757,10 @@ func (r *ClickHouseReader) GetTopOperations(ctx context.Context, queryParams *mo
quantile(0.95)(durationNano) as p95, quantile(0.95)(durationNano) as p95,
quantile(0.99)(durationNano) as p99, quantile(0.99)(durationNano) as p99,
COUNT(*) as numCalls, COUNT(*) as numCalls,
countIf(statusCode=2) as errorCount, countIf(status_code=2) as errorCount,
name name
FROM %s.%s FROM %s.%s
WHERE serviceName = @serviceName AND timestamp>= @start AND timestamp<= @end`, WHERE resource_string_service$$name = @serviceName AND timestamp>= @start AND timestamp<= @end`,
r.TraceDB, r.traceTableName, r.TraceDB, r.traceTableName,
) )