blob: 4c63218448d9dc2e85b241ade0c6928c0b851cd9 (
plain)
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
#!/usr/bin/python3
import sys
from datetime import datetime, timedelta
from flask.ext.script import Command, Option
from pyaggr3g470r.controllers \
import UserController, FeedController, ArticleController
DEFAULT_HEADERS = {'Content-Type': 'application/json', 'User-Agent': 'munin'}
LATE_AFTER = 60
FETCH_RATE = 3
class AbstractMuninPlugin(Command):
urn = None
def execute(self):
raise NotImplementedError()
def config(self):
raise NotImplementedError()
def get_options(self):
if sys.argv[-1] == 'config':
return [Option(dest='config', default=sys.argv[-1] == 'config')]
return []
def run(self, config=False):
if config:
self.config()
else:
self.execute()
class FeedProbe(AbstractMuninPlugin):
def config(self):
print("graph_title PyAgg - Feeds counts")
print("graph_vlabel feeds")
print("feeds.label Late feeds")
print("feeds_total.label Total feeds")
print("feeds.warning 15")
print("feeds.critical 30")
print("graph_category web")
print("graph_scale yes")
def execute(self):
delta = datetime.now() - timedelta(minutes=LATE_AFTER + FETCH_RATE + 1)
total = FeedController().read().count()
print("feeds.value %d"
% len(FeedController().list_late(delta, limit=total)))
print("feeds_total.value %d" % FeedController().read().count())
class ArticleProbe(AbstractMuninPlugin):
def config(self):
print("graph_title Pyagg - Articles adding rate")
print("graph_vlabel Articles per sec")
print("articles.label Overall rate")
print("articles.type DERIVE")
print("articles.min 0")
for id_ in sorted(user.id for user in UserController().read()):
print("articles_user_%s.label Rate for user %s" % (id_, id_))
print("articles_user_%s.type DERIVE" % id_)
print("articles_user_%s.min 0" % id_)
print("graph_category web")
print("graph_scale yes")
def execute(self):
counts = ArticleController().count_by_user_id()
print("articles.value %s" % sum(counts.values()))
for user, count in counts.items():
print("articles_user_%s.value %s" % (user, count))
|
