projects/weather-api
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

create flux query

Browse source
This commit is contained in:
Joel Schmid 2021-03-20 21:31:20 +01:00
parent 3d261df142
commit ce22efcb96
1 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
storage/influxdb-storage.go
View file

@ -54,7 +54,12 @@ func (storage *influxStorage) Save(data WeatherData) error {
//GetData datapoints from InfluxDB
func (storage *influxStorage) GetData(query *WeatherQuery) ([]*WeatherData, error) {
fluxQuery := storage.createFluxQuery(query)
res, err := storage.executeFluxQuery(fluxQuery)
return res, err
}
func (storage *influxStorage) createFluxQuery(query *WeatherQuery) string {
fields := ""
concat := ""
@ -81,9 +86,7 @@ func (storage *influxStorage) GetData(query *WeatherQuery) ([]*WeatherData, erro
fields = fmt.Sprintf(" and ( %v )", fields)
fluxQuery := fmt.Sprintf("from(bucket:\"%v\")|> range(start: %v, stop: %v) |> filter(fn: (r) => r._measurement == \"%v\" and r.sensorId == \"%v\" %v)", storage.bucket, query.Start.Format(time.RFC3339), query.End.Format(time.RFC3339), storage.measurement, query.SensorId, fields)
res, err := storage.executeFluxQuery(fluxQuery)
return res, err
return fluxQuery
}
func (storage *influxStorage) executeFluxQuery(query string) ([]*WeatherData, error) {