Timestream DB Client

Client to import measurements to timestream databases.

Supported Databases/Services

• AWS Timestream

AWS Timestream

Run NewTimestreamPublisher to create a new client for AWS Timestream. You've to pass a config which defines region, database, table name and batch size. If you don't pass a logger a new stdout logger will be created. See https://github.com/tommzn/go-log for more details about used logger.

package main

import (
    "fmt"

    metrics "github.com/tommzn/go-metrics"
    config "github.com/tommzn/go-config"
)

func main() {

    // Assumes a config.yml file in current folter.
    conf, err := config.NewConfigSource().Load()
    if err != nil {
        panic(err)
    }
    publisher := metrics.NewTimestreamPublisher(conf. nil)
    measurement := Measurement{
		MetricName: "test-metric",
		Tags: []MeasurementTag{MeasurementTag{
			Name:  "host",
			Value: "ip-10.0.1.12",
		}},
		Values: []MeasurementValue{MeasurementValue{
			Name:  "load",
			Value: 0.53,
		}},
	}

    // If batch size is not set or 0 this will directly import passed measurement to AWS Timestream.
    publisher.Send(measurement)
    // To ensure import of a aavailable measurements you've to flush the publisher.
    publisher.Flush()

    // Any errors that occur when importing measurements are collected.
    if err := publisher.Error(); err != nil {
        fmt.Println(err)
    }
}

Config

Following examples show a config with all available values.

aws:
  timestream:
    awsregion: eu-west-1
    database: timestream-db
    table: data
    batch_size: 10

AWS Credentials

Credentials for AWS access have to be setup separately as described in AWS SDK Docs.