mirror of
https://git.mirrors.martin98.com/https://github.com/SigNoz/signoz
synced 2025-07-30 21:02:03 +08:00
timestamp in ns from ms
This commit is contained in:
parent
c24bdfc8cf
commit
a527c33c7d
@ -2995,12 +2995,12 @@ func (r *ClickHouseReader) AggregateLogs(ctx context.Context, params *model.Logs
|
|||||||
|
|
||||||
query := ""
|
query := ""
|
||||||
if groupBy != "" {
|
if groupBy != "" {
|
||||||
query = fmt.Sprintf("SELECT toInt64(toUnixTimestamp(toStartOfInterval(toDateTime(timestamp/1000), INTERVAL %d minute))*1000) as time, toString(%s) as groupBy, "+
|
query = fmt.Sprintf("SELECT toInt64(toUnixTimestamp(toStartOfInterval(toDateTime(timestamp/1000000000), INTERVAL %d minute))*1000000000) as time, toString(%s) as groupBy, "+
|
||||||
"%s "+
|
"%s "+
|
||||||
"FROM %s.%s WHERE timestamp >= '%d' AND timestamp <= '%d' ",
|
"FROM %s.%s WHERE timestamp >= '%d' AND timestamp <= '%d' ",
|
||||||
*params.StepSeconds/60, groupBy, function, r.logsDB, r.logsTable, *params.TimestampStart, *params.TimestampEnd)
|
*params.StepSeconds/60, groupBy, function, r.logsDB, r.logsTable, *params.TimestampStart, *params.TimestampEnd)
|
||||||
} else {
|
} else {
|
||||||
query = fmt.Sprintf("SELECT toInt64(toUnixTimestamp(toStartOfInterval(toDateTime(timestamp/1000), INTERVAL %d minute))*1000) as time, "+
|
query = fmt.Sprintf("SELECT toInt64(toUnixTimestamp(toStartOfInterval(toDateTime(timestamp/1000000000), INTERVAL %d minute))*1000000000) as time, "+
|
||||||
"%s "+
|
"%s "+
|
||||||
"FROM %s.%s WHERE timestamp >= '%d' AND timestamp <= '%d' ",
|
"FROM %s.%s WHERE timestamp >= '%d' AND timestamp <= '%d' ",
|
||||||
*params.StepSeconds/60, function, r.logsDB, r.logsTable, *params.TimestampStart, *params.TimestampEnd)
|
*params.StepSeconds/60, function, r.logsDB, r.logsTable, *params.TimestampStart, *params.TimestampEnd)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user