File tree Expand file tree Collapse file tree
telemetryService/golang/internal/adapter/questdb Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -43,6 +43,7 @@ tokens/
4343credentials /
4444auth_credentials.txt
4545ingest /go /ibt_files /*
46+ ingest /go /handful_ibt_files /*
4647* .DS_Store
4748.DS_Store
4849** /.env.influxdb-admin-password
Original file line number Diff line number Diff line change @@ -16,6 +16,7 @@ func NewSchema(host string, port int) *Schema {
1616 return & Schema {host : host , port : port }
1717}
1818
19+ // todo: add retry logic to stop it falling over on the pi
1920func (s * Schema ) CreateTableHTTP () error {
2021 sql := `
2122 CREATE TABLE IF NOT EXISTS TelemetryTicks (
@@ -64,7 +65,7 @@ func (s *Schema) CreateTableHTTP() error {
6465 lRtempM DOUBLE,
6566 rRtempM DOUBLE,
6667 timestamp TIMESTAMP
67- ) TIMESTAMP(timestamp) PARTITION BY DAY
68+ ) TIMESTAMP(timestamp) PARTITION BY DAY
6869 WAL
6970 WITH maxUncommittedRows=1000000
7071 DEDUP UPSERT KEYS(timestamp, session_id);
You can’t perform that action at this time.
0 commit comments