tokio.connectors.collectd_es module

Retrieve data generated by collectd and stored in Elasticsearch

class tokio.connectors.collectd_es.CollectdEs(*args, **kwargs)

Bases: tokio.connectors.es.EsConnection

collectd-Elasticsearch connection handler

_query_timeseries(query_template, start, end)

Map connection-wide attributes to self.query_timeseries arguments

Parameters:

• query_template (dict) – a query object containing at least one @timestamp field
• start (datetime.datetime) – lower bound for query (inclusive)
• end (datetime.datetime) – upper bound for query (exclusive)

classmethod from_cache(*args, **kwargs)

Initializes an EsConnection object from a cache file.

This path is designed to be used for testing.

Parameters:cache_file (str) – Path to the JSON formatted list of pages

query_cpu(start, end)

Query Elasticsearch for collectd cpu plugin data.

Parameters:

• start (datetime.datetime) – lower bound for query (inclusive)
• end (datetime.datetime) – upper bound for query (exclusive)

query_disk(start, end)

Query Elasticsearch for collectd disk plugin data.

Parameters:

• start (datetime.datetime) – lower bound for query (inclusive)
• end (datetime.datetime) – upper bound for query (exclusive)

query_memory(start, end)

Query Elasticsearch for collectd memory plugin data.

Parameters:

• start (datetime.datetime) – lower bound for query (inclusive)
• end (datetime.datetime) – upper bound for query (exclusive)

to_dataframe()

Converts self.scroll_pages to a DataFrame

Returns:Contents of the last query’s pages Return type:pandas.DataFrame