Telemetry

class datalake.telemetry.Measurement(name, start_time=None)[source]

Represents a point of measurement consisting in a starting time, a set of measures and a set of labels

Parameters

  • name (str) – the name for the measurement

  • start_time (time) – the time when measurement started. Defaults to current UTC time.

add_label(key, value)[source]

Appends a single label

Parameters

  • key (str) – the label name

  • value (str) – the label value

add_labels(labels)[source]

Appends a batch of labels

Parameters

labels (dict) – a key pair map of label names and values

add_measure(key, value)[source]

Appends a single measure

Parameters

  • key (str) – the measure name

  • value (double) – the measure value

add_measures(measures)[source]

Appends a batch of measures

Parameters

measures (dict) – a key pair map of measure names and values

property labels

The dict of labels attached with the measurment

property measures

The dict of measure values. Defaults to {"file_count": 1}

property name

The name of the measurement

read_chrono()[source]

Returns the elapsed time since last reset or since initialization

reset_chrono()[source]

Resets the counter used for evaluating elapsed time

property start_time

The reference starting time for the measurement