-
Notifications
You must be signed in to change notification settings - Fork 14
/
example-stats-client.tac
52 lines (37 loc) · 1.36 KB
/
example-stats-client.tac
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
import socket
import random
from twisted.internet import reactor
from twisted.internet import task
from twisted.application.service import Application
from txstatsd.client import (
TwistedStatsDClient, StatsDClientProtocol)
from txstatsd.metrics.metrics import Metrics
from txstatsd.process import PROCESS_STATS
from txstatsd.report import ReportingService
STATSD_HOST = "127.0.0.1"
STATSD_PORT = 8125
application = Application("example-stats-client")
statsd_client = TwistedStatsDClient(STATSD_HOST, STATSD_PORT)
metrics = Metrics(connection=statsd_client,
namespace=socket.gethostname() + ".example-client")
reporting = ReportingService()
reporting.setServiceParent(application)
for report in PROCESS_STATS:
reporting.schedule(report, 10, metrics.increment)
def random_walker(name):
"""Meters a random walk."""
if random.random() > 0.5:
metrics.increment(name)
else:
metrics.decrement(name)
def random_normal(name):
"""Meters samples from a normal distribution."""
metrics.timing(name, random.normalvariate(10, 3))
for n in range(5):
t = task.LoopingCall(random_walker, name="walker%i" % n)
t.start(0.5, now=False)
for n in range(5):
t = task.LoopingCall(random_normal, name="normal%i" % n)
t.start(0.5, now=False)
protocol = StatsDClientProtocol(statsd_client)
reactor.listenUDP(0, protocol)