Prometheus Push Cli

The prom-push-cli is made for testing purpose and for jobs which expose their metrics to Prometheus without scraping method like stdout or a custom file.

Note: the node exporter text-file collector could be used if metrics are related to the node.

The prom-push-cli is not an alternative to:

How it works

The prom-push-cli read input from stdin and use expfmt to extract the timeseries from flat text-based exchange format and creates MetricFamily proto messages.

Then it create a WriteRequest object, serialize it and send as an HTTP request with snappy-compressed protocol buffer.

This help to be a bit more performant with reducing the payload size.

Usage

Usage of prom-push-cli:
  -debug
      Enable verbose mode
  -header value
      The prometheus remote write header like key="value", repeatable
  -job-label string
      The prometheus remote write job label to add (default "prom-push-cli")
  -timeout int
      The prometheus remote write timeout (default 30)
  -tls-ca-file string
      The prometheus remote write TLS ca file
  -tls-cert-file string
      The prometheus remote write TLS cert file
  -tls-key-file string
      The prometheus remote write TLS key file
  -tls-skip-verify
      Disables the prometheus remote write TLS verify
  -url string
      The prometheus remote write url

Run it

With Headers

echo 'custom_metric_info{test="manual"} 1.' | ./prom-push-cli -url http://my-remote-write:10001/api/v1/push -header Authorization="Basic 123456" -header tenant=test

Without TLS

echo 'custom_metric_info{test="manual"} 1.' | ./prom-push-cli -url http://my-remote-write:10001/api/v1/push

With TLS Insecure

echo 'custom_metric_info{test="manual"} 1.' | ./prom-push-cli -url https://my-remote-write:10001/api/v1/push -tls-skip-verify

With TLS

echo 'custom_metric_info{test="manual"} 1.' | ./prom-push-cli -url http://my-remote-write:10001/api/v1/push -tls-cert-file mycert.crt -tls-key-file my-key.pem -tls-ca-file myca.crt

With Debug mode

cat /tmp/metric 
custom_metric_info{test="manual"} 1
custom_metric_info{test="manual2"} 1


cat /tmp/metric | ./prom-push-cli -url http://my-remote-write:10001/api/v1/push -debug
2022/03/16 11:48:48 Sending 2 timeseries
2022/03/16 11:48:48 POST /api/v1/push HTTP/1.1
Host: my-remote-write:10001
Content-Encoding: snappy
Content-Type: application/x-protobuf
X-Prometheus-Remote-Write-Version: 0.1.0
[...]
2022/03/16 11:48:48 method=POST url=http://my-remote-write:10001/api/v1/push length=92 status=200 duration=40

Integrate prom-push-cli to your code

import (
  "strings"
  "github.com/fgouteroux/prom-push-cli/pkg/client"
  "github.com/fgouteroux/prom-push-cli/pkg/metrics"
  "log"
)

func main() {
  // create io.reader with metrics to send
  metrics_reader := strings.NewReader("custom_metric{label1=\"value1\"} 1\n")

  // ParseAndFormat return the data in the expected prometheus metrics write request format
  // Second arg is the job label to attach to timeseries
  data, err := metrics.ParseAndFormat(metrics_reader, "job-test")
  if err != nil {
    log.Fatal(err)
  }

  // Configure client with remote write url and others settings
  var headers []string
  promClient := client.Configure("http://my-remote-write:10001/api/v1/push", false, 30, headers)

  // Push timeseries with a backoff retry in case of errors
  err = promClient.PushWithRetries(data)
  if err != nil {
    log.Fatal(err)
  }
}

TODO

add tests...

License

Licensed under the terms of the Apache License, Version 2.0.

References

Inspired by:

jpatigny/prom-push-cli