Skip to content

Commit 64b7af1

Browse files
committed
fix(internal): update ClickHouse timestamp formatting to include microseconds
1 parent 43d061c commit 64b7af1

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

internal/custom-kafka-to-flexprice-clickhouse.yaml

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -57,11 +57,11 @@ pipeline:
5757
# Timestamp: parse ISO 8601 with timezone, then format for ClickHouse
5858
# 1. Check if createdAt exists and is valid
5959
# 2. Parse it as timestamp to preserve timezone info
60-
# 3. Format to ClickHouse DateTime64 format: "2006-01-02 15:04:05.999"
60+
# 3. Format to ClickHouse DateTime64 format: "2006-01-02 15:04:05.999999"
6161
root.timestamp = if this.createdAt != null && this.createdAt.string().or("") != "" && this.createdAt.string() != "null" {
62-
this.createdAt.ts_parse("2006-01-02T15:04:05Z07:00").ts_format("2006-01-02 15:04:05.999")
62+
this.createdAt.ts_parse("2006-01-02T15:04:05.999Z07:00").ts_format("2006-01-02 15:04:05.999999")
6363
} else {
64-
timestamp_unix().ts_format("2006-01-02 15:04:05.999")
64+
timestamp_unix().ts_format("2006-01-02 15:04:05.999999")
6565
}
6666
6767
# ---- Build event_name SAFELY ----

0 commit comments

Comments
 (0)