Flux InfluxDB

v0.0.3

Flux InfluxDB v0.0.3 FluxInfluxDB View Source

Manage InfluxDB data.

Link to this section Summary

Functions

delete!(query_map, measurement, database, options \\ [])

Delete points based on query.

drop_database!(database)

Remove database and its data.

read!(query_map, measurement, database, options \\ [])

Search for points based on query.

write!(payload, tags_keys, measurement, database, options \\ [])

Write a point.

Link to this section Functions

Link to this function

delete!(query_map, measurement, database, options \\ [])

View Source (since 0.0.1) 
delete!(map(), String.t(), String.t(), keyword()) :: :ok

Delete points based on query.

Parameters

Examples 

iex> FluxInfluxDB.delete!(%{}, "my_measurement", "my_database")
:ok
Link to this function

drop_database!(database)

View Source (since 0.0.1) 
drop_database!(String.t()) :: :ok

Remove database and its data.

Parameters

Examples 

iex> FluxInfluxDB.drop_database!("my_database")
:ok
Link to this function

read!(query_map, measurement, database, options \\ [])

View Source (since 0.0.1) 
read!(map(), String.t(), String.t(), keyword()) :: [map()]

Search for points based on query.

Parameters

Examples 

iex> FluxInfluxDB.write!(%{"hello" => "world"}, [], "my_measurement", "my_database")
...> FluxInfluxDB.write!(%{"hello" => "human"}, [], "my_measurement", "my_database")
...> query_map = %{"where" => %{"hello" => "world"}}
...> [%{"hello" => name}] = FluxInfluxDB.read!(query_map, "my_measurement", "my_database")
...> name
"world"
Link to this function

write!(payload, tags_keys, measurement, database, options \\ [])

View Source (since 0.0.1) 
write!(map(), [String.t()], String.t(), String.t(), keyword()) :: :ok

Write a point.

If database does not exist, it will be created.

Parameters

Examples 

iex> FluxInfluxDB.write!(%{"hello" => "world"}, [], "my_measurement", "my_database")
:ok