Version: v0.10.1 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Jan 27, 2016 License: MIT Imports: 13 Imported by: 0


Amazon Kinesis Output for Telegraf

This is an experimental plugin that is still in the early stages of development. It will batch up all of the Points in one Put request to Kinesis. This should save the number of API requests by a considerable level.

About Kinesis

This is not the place to document all of the various Kinesis terms however it maybe useful for users to review Amazons official documentation which is available here.

Amazon Authentication

This plugin uses a credential chain for Authentication with the Kinesis API endpoint. In the following order the plugin will attempt to authenticate.

  1. IAMS Role
  2. Environment Variables
  3. Shared Credentials


For this output plugin to function correctly the following variables must be configured.

  • region
  • streamname
  • partitionkey


The region is the Amazon region that you wish to connect to. Examples include but are not limited to

  • us-west-1
  • us-west-2
  • us-east-1
  • ap-southeast-1
  • ap-southeast-2


The streamname is used by the plugin to ensure that data is sent to the correct Kinesis stream. It is important to note that the stream MUST be pre-configured for this plugin to function correctly. If the stream does not exist the plugin will result in telegraf exiting with an exit code of 1.


This is used to group data within a stream. Currently this plugin only supports a single partitionkey. Manually configuring different hosts, or groups of hosts with manually selected partitionkeys might be a workable solution to scale out.


The format configuration value has been designated to allow people to change the format of the Point as written to Kinesis. Right now there are two supported formats string and custom.


String is defined using the default Point.String() value and translated to []byte for the Kinesis stream.


Custom is a string defined by a number of values in the FormatMetric() function.




This section is empty.


This section is empty.


func FormatMetric

func FormatMetric(k *KinesisOutput, point *client.Point) (string, error)


type KinesisOutput

type KinesisOutput struct {
	Region       string `toml:"region"`
	StreamName   string `toml:"streamname"`
	PartitionKey string `toml:"partitionkey"`
	Format       string `toml:"format"`
	Debug        bool   `toml:"debug"`
	// contains filtered or unexported fields

func (*KinesisOutput) Close

func (k *KinesisOutput) Close() error

func (*KinesisOutput) Connect

func (k *KinesisOutput) Connect() error

func (*KinesisOutput) Description

func (k *KinesisOutput) Description() string

func (*KinesisOutput) SampleConfig

func (k *KinesisOutput) SampleConfig() string

func (*KinesisOutput) Write

func (k *KinesisOutput) Write(points []*client.Point) error

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL