diff options
-rwxr-xr-x | src/manager.py | 3 | ||||
-rw-r--r-- | src/scripts/__init__.py | 0 | ||||
-rw-r--r-- | src/scripts/probes.py | 74 |
3 files changed, 0 insertions, 77 deletions
diff --git a/src/manager.py b/src/manager.py index 14139ec2..b6ff87a0 100755 --- a/src/manager.py +++ b/src/manager.py @@ -70,9 +70,6 @@ def fetch_asyncio(user_id, feed_id): classic_crawler.retrieve_feed(loop, g.user, feed_id) loop.close() -from scripts.probes import ArticleProbe, FeedProbe -manager.add_command('probe_articles', ArticleProbe()) -manager.add_command('probe_feeds', FeedProbe()) if __name__ == '__main__': manager.run() diff --git a/src/scripts/__init__.py b/src/scripts/__init__.py deleted file mode 100644 index e69de29b..00000000 --- a/src/scripts/__init__.py +++ /dev/null diff --git a/src/scripts/probes.py b/src/scripts/probes.py deleted file mode 100644 index 94ca25fc..00000000 --- a/src/scripts/probes.py +++ /dev/null @@ -1,74 +0,0 @@ -#!/usr/bin/python3 -import sys -from datetime import datetime, timedelta -from flask.ext.script import Command, Option - -from web.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)) |