influxdb

README

InfluxDB

An Open-Source, Distributed, Time Series Database

InfluxDB v0.9.0 is now out. Going forward, the 0.9.x series of releases will not make breaking API changes or breaking changes to the underlying data storage. However, 0.9.x clustering should be considered an alpha release.

InfluxDB is an open source distributed time series database with no external dependencies. It's useful for recording metrics, events, and performing analytics.

Features

• Built-in HTTP API so you don't have to write any server side code to get up and running.
• Data can be tagged, allowing very flexible querying.
• SQL-like query language.
• Clustering is supported out of the box, so that you can scale horizontally to handle your data.
• Simple to install and manage, and fast to get data in and out.
• It aims to answer queries in real-time. That means every data point is indexed as it comes in and is immediately available in queries that should return in < 100ms.

Getting Started

The following directions apply only to the 0.9.x series or building from the source on master.

Building

You don't need to build the project to use it - you can use any of our pre-built packages to install InfluxDB. That's the recommended way to get it running. However, if you want to contribute to the core of InfluxDB, you'll need to build. For those adventurous enough, you can follow along on our docs.

Starting InfluxDB

• service influxdb start if you have installed InfluxDB using an official Debian or RPM package.
• systemctl start influxdb if you have installed InfluxDB using an official Debian or RPM package, and are running a distro with systemd. For example, Ubuntu 15 or later.
• $GOPATH/bin/influxd if you have built InfluxDB from source.

Creating your first database

curl -G 'http://localhost:8086/query' --data-urlencode "q=CREATE DATABASE mydb"

Insert some data

curl -XPOST 'http://localhost:8086/write?db=mydb' \
-d 'cpu,host=server01,region=uswest load=42 1434055562000000000'

curl -XPOST 'http://localhost:8086/write?db=mydb' \
-d 'cpu,host=server02,region=uswest load=78 1434055562000000000'

curl -XPOST 'http://localhost:8086/write?db=mydb' \
-d 'cpu,host=server03,region=useast load=15.4 1434055562000000000'

Query for the data

curl -G http://localhost:8086/query?pretty=true --data-urlencode "db=mydb" \
--data-urlencode "q=SELECT * FROM cpu WHERE host='server01' AND time < now() - 1d"

Analyze the data

curl -G http://localhost:8086/query?pretty=true --data-urlencode "db=mydb" \
--data-urlencode "q=SELECT mean(load) FROM cpu WHERE region='uswest'"

Helpful Links

• Understand the design goals and motivations of the project.
• Follow the getting started guide to find out how to install InfluxDB, start writing more data, and issue more queries - in just a few minutes.
• See the HTTP API documentation to start writing a library for your favorite language.

Looking for Support?

InfluxDB has technical support subscriptions to help your project succeed. We offer Developer Support for organizations in active development and Production Support for companies requiring the best response times and SLAs on technical fixes. Visit our support page to learn which subscription is right for you, or contact sales@influxdb.com for a quote.

Documentation

Index

• Variables
• func ErrDatabaseNotFound(name string) error
• func ErrRetentionPolicyNotFound(name string) error
• func IsClientError(err error) bool
• func NewStatistics(key, name string, tags map[string]string) *expvar.Map
• type Node
  • func LoadNode(path string, addrs []string) (*Node, error)
  • func NewNode(path string, addrs []string) *Node
  • func (n *Node) AddMetaServers(addrs []string)
  • func (n *Node) Save() error

Variables

var (
	// ErrFieldsRequired is returned when a point does not any fields.
	ErrFieldsRequired = errors.New("fields required")

	// ErrFieldTypeConflict is returned when a new field already exists with a different type.
	ErrFieldTypeConflict = errors.New("field type conflict")
)

Functions

func ErrDatabaseNotFound

func ErrDatabaseNotFound(name string) error

ErrDatabaseNotFound indicates that a database operation failed on the specified database because the specified database does not exist.

func ErrRetentionPolicyNotFound

func ErrRetentionPolicyNotFound(name string) error

ErrRetentionPolicyNotFound indicates that the named retention policy could not be found in the database.

func IsClientError

func IsClientError(err error) bool

IsClientError indicates whether an error is a known client error.

func NewStatistics

func NewStatistics(key, name string, tags map[string]string) *expvar.Map

NewStatistics returns an expvar-based map with the given key. Within that map is another map. Within there "name" is the Measurement name, "tags" are the tags, and values are placed at the key "values".

Types

type Node

type Node struct {
	ID          uint64
	MetaServers []string
	// contains filtered or unexported fields
}

func LoadNode

func LoadNode(path string, addrs []string) (*Node, error)

LoadNode will load the node information from disk if present

func NewNode

func NewNode(path string, addrs []string) *Node

NewNode will return a new node

func (*Node) AddMetaServers

func (n *Node) AddMetaServers(addrs []string)

AddMetaServers adds the addrs to the set of MetaServers known to this node. If an addr already exists, it will not be re-added.

func (*Node) Save

func (n *Node) Save() error

Save will save the node file to disk and replace the existing one if present