The StatsClient provides accessors for all the types of data the statsd server supports.
Note
Each public stats API method supports a rate parameter, but statsd doesn’t always use it the same way. See the Data Types for more information.
StatsClient(host='localhost', port=8125, prefix=None, maxudpsize=512)
Create a new StatsClient instance with the appropriate connection and prefix information.
StatsClient().incr(stat, count=1, rate=1)
Increment a counter.
StatsClient().decr(stat, count=1, rate=1)
Decrement a counter.
StatsClient().gauge(stat, value, rate=1, delta=False)
Set a gauge value.
Note
Gauges were added to the statsd server in commit 0ed78be. If you try to use this method with an older version of the server, the data will not be recorded.
StatsClient().set(stat, value, rate=1)
Increment a set value.
Note
Sets were added to the statsd server in commit 1c10cfc0ac. If you try to use this method with an older version of the server, the data will not be recorded.
StatsClient().timing(stat, delta, rate=1)
Record timer information.
with StatsClient().timer(stat, rate=1):
pass
@StatsClient().timer(stat, rate=1)
def foo():
pass
timer = StatsClient().timer('foo', rate=1)
Automatically record timing information for a managed block or function call. See also the chapter on timing.
Warning
Decorators are not thread-safe and may cause errors when decorated functions are called concurrently. Use context managers or raw timers instead.
StatsClient().timer('foo').start()
Causes a timer object to start counting. Called automatically when the object is used as a decorator or context manager. Returns the timer object for simplicity.
timer = StatsClient().timer('foo').start()
timer.stop()
Causes the timer object to stop timing and send the results to statsd. Can be called with send=False to prevent immediate sending immediately, and use send(). Called automatically when the object is used as a decorator or context manager. Returns the timer object.
If stop() is called before start(), a RuntimeError is raised.
timer = StatsClient().timer('foo').start()
timer.stop(send=False)
timer.send()
Causes the timer to send any unsent data. If the data has already been sent, or has not yet been recorded, a RuntimeError is raised.
Note
See the note abbout timer objects and pipelines.
StatsClient().pipeline()
Returns a Pipeline object for collecting several stats. Can also be used as a context manager:
with StatsClient().pipeline() as pipe:
pipe.incr('foo')
TCPStatsClient(host='localhost', port=8125, prefix=None, timeout=None)
Create a new TCPStatsClient instance with the appropriate connection and prefix information.
TCPStatsClient implements all methods of StatsClient, including pipeline(), with the difference that it is not thread safe and it can raise exceptions on connection errors. Unlike StatsClient it uses a TCP connection to communicate with StatsD.
In addition to the stats methods, TCPStatsClient supports the following TCP-specific methods.
from statsd import TCPStatsClient
statsd = TCPStatsClient()
statsd.incr('some.event')
statsd.close()
Closes a connection that’s currently open and deletes it’s socket. If this is called on a TCPStatsClient which currently has no open connection it is a non-action.
from statsd import TCPStatsClient
statsd = TCPStatsClient()
statsd.incr('some.event') # calls connect() internally
statsd.close()
statsd.connect() # creates new connection
Creates a connection to StatsD. If there are errors like connection timed out or connection refused, the according exceptions will be raised. It is usually not necessary to call this method because sending data to StatsD will call connect implicitely if the current instance of TCPStatsClient does not already hold an open connection.
from statsd import TCPStatsClient
statsd = TCPStatsClient()
statsd.incr('some.event')
statsd.reconnect() # closes open connection and creates new one
Closes a currently existing connection and replaces it with a new one. If no connection exists already it will simply create a new one. Internally this does nothing else than calling close() and connect().