2018-12-28 19:53:04 +01:00
|
|
|
import argparse
|
|
|
|
import json
|
|
|
|
|
2018-12-28 20:12:11 +01:00
|
|
|
import dateutil
|
|
|
|
from django.conf import settings
|
2018-12-28 19:53:04 +01:00
|
|
|
from django.core.management.base import BaseCommand
|
|
|
|
from django.utils.translation import ugettext_lazy as _
|
|
|
|
|
|
|
|
from c3nav.mapdata.utils.cache.stats import convert_stats
|
|
|
|
|
|
|
|
|
|
|
|
class Command(BaseCommand):
|
|
|
|
help = 'convert stats file'
|
|
|
|
|
|
|
|
def add_arguments(self, parser):
|
|
|
|
parser.add_argument('statsfile', type=argparse.FileType('r'), help=_('stats file to convert'))
|
2018-12-28 20:12:11 +01:00
|
|
|
parser.add_argument('--graphite', action='store_const', const=True, default=False,
|
|
|
|
help=_('graphite format'))
|
|
|
|
|
|
|
|
def _output_graphite(self, prefix, result, timestamp):
|
|
|
|
for name, value in result.items():
|
|
|
|
if isinstance(value, dict):
|
|
|
|
self._output_graphite(prefix+name+'.', value, timestamp)
|
|
|
|
continue
|
|
|
|
print('%s%s %s %s' % (prefix, name, value, timestamp))
|
2018-12-28 19:53:04 +01:00
|
|
|
|
|
|
|
def handle(self, *args, **options):
|
|
|
|
data = json.load(options['statsfile'])
|
2018-12-28 20:12:11 +01:00
|
|
|
end_time = int(dateutil.parser.parse(data['end_date']).timestamp())
|
2018-12-28 19:53:04 +01:00
|
|
|
result = convert_stats(data)
|
2018-12-28 20:12:11 +01:00
|
|
|
if options['graphite']:
|
|
|
|
self._output_graphite('c3nav.%s.' % settings.INSTANCE_NAME, result, end_time)
|
|
|
|
else:
|
|
|
|
print(json.dumps(result, indent=4))
|