This is a python implementation of the MetricQ protocol. It allows you to write Sources and Sinks to easily send and receive data over the MetricQ infrastructure.
Install the package from PyPI:
$ pip install metricqThe examples directory contains some basic
examples.
To play around with them, check out a copy of this repository and (in your
favourite venv) install their dependencies:
$ pip install -e '.[examples]'A simple Source is implemented in metricq_source.py, as is a Sink in metricq_sink.py.
We will use the former to produce data for a metric called test.py.dummy, which we
will then receive and print with the latter.
Assuming a MetricQ instance is reachable at localhost, configure a
client(consult the documentation of your favourite config provider on how
to do that) named source-py-dummy to produce values with a frequence of
0.5Hz (i.e. every 2 seconds) :
{
"rate": 0.5
}To start the Source, run:
$ ./examples/metricq_source.py --server 'amqp://localhost/' --token 'source-py-dummy'This should now send values for the metric test.py.dummy in 2-second intervals.
To see (in detail) what's going on, add -v DEBUG to the arguments above.
On the other side, run
$ ./examples/metricq_sink.py --server 'amqp://localhost/' --metrics 'test.py.dummy'and you should see new values for the metric test.py.dummy appear ever 2 seconds.