added minutes in destination file

Author: rjtokenring

README.md

@@ -2,7 +2,9 @@
 
 This project provides a way to extract time series samples from Arduino cloud, publishing to a S3 destination bucket.
 Data are extracted at the given resolution via a scheduled Lambda function. Then samples are stored in CSV files and saved to S3.
-By default, data extraction is performed every hour, extracting samples aggregated at 5min resolution. Non numeric values like strings are sampled at the given resolution.
+By default, data extraction is performed every hour (configurable), extracting samples aggregated at 5min resolution (configurable).
+Aggregation is performed as average over aggregation period.
+Non numeric values like strings are sampled at the given resolution.
 
 ## Architecture
 

business/tsextractor/tsextractor.go

@@ -128,7 +128,7 @@ func (a *TsExtractor) ExportTSToS3(
 	writer.Close()
 	defer writer.Delete()
 
-	destinationKey := fmt.Sprintf("%s/%s.csv", from.Format("2006-01-02"), from.Format("2006-01-02-15"))
+	destinationKey := fmt.Sprintf("%s/%s.csv", from.Format("2006-01-02"), from.Format("2006-01-02-15-04"))
 	a.logger.Infof("Uploading file %s to bucket %s\n", destinationKey, s3cl.DestinationBucket())
 	if err := s3cl.WriteFile(ctx, destinationKey, writer.GetFilePath()); err != nil {
 		return err

internal/csv/csv.go

@@ -18,7 +18,7 @@ const (
 var csvHeader = []string{"timestamp", "thing_id", "thing_name", "property_id", "property_name", "property_type", "value"}
 
 func NewWriter(destinationHour time.Time, logger *logrus.Entry) (*CsvWriter, error) {
-	filePath := fmt.Sprintf("%s/%s.csv", baseTmpStorage, destinationHour.Format("2006-01-02-15:04"))
+	filePath := fmt.Sprintf("%s/%s.csv", baseTmpStorage, destinationHour.Format("2006-01-02-15-04"))
 	file, err := os.Create(filePath)
 	if err != nil {
 		logger.Fatalf("failed creating file: %s", err)