x/stacktach
Code Issues Proposed changes

Refactor verifier audit functions

Browse Source
This commit is contained in:
Andrew Melton 2014-03-05 14:25:04 -05:00
parent a5d4836e12
commit 8bae0d4cfc
1 changed files with 16 additions and 40 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
reports/usage_audit.py
View File

@ -70,42 +70,31 @@ def _audit_for_exists(exists_query):
return report return report
def _verifier_audit_for_day(beginning, ending, exists_model): def _verified_audit_base(base_query, exists_model):
summary = {} summary = {}
filters = { periodic_range = Q(audit_period_ending=(F('audit_period_beginning') +
'raw__when__gte': beginning, (60*60*24)))
'raw__when__lte': ending, periodic_exists = exists_model.objects.filter(base_query & periodic_range)
'audit_period_ending': F('audit_period_beginning') + (60*60*24)
}
periodic_exists = exists_model.objects.filter(**filters)
summary['periodic'] = _audit_for_exists(periodic_exists) summary['periodic'] = _audit_for_exists(periodic_exists)
filters = { instant_range = Q(audit_period_ending__lt=(F('audit_period_beginning') +
'raw__when__gte': beginning, (60*60*24)))
'raw__when__lte': ending, instant_exists = exists_model.objects.filter(base_query & instant_range)
'audit_period_ending__lt': F('audit_period_beginning') + (60*60*24)
}
instant_exists = exists_model.objects.filter(**filters)
summary['instantaneous'] = _audit_for_exists(instant_exists) summary['instantaneous'] = _audit_for_exists(instant_exists)
filters = { failed_query = Q(status=exists_model.FAILED)
'raw__when__gte': beginning, failed = exists_model.objects.filter(base_query & failed_query)
'raw__when__lte': ending, detail = [['Exist', e.id, e.fail_reason] for e in failed]
'status': exists_model.FAILED
}
failed = exists_model.objects.filter(**filters)
detail = []
for exist in failed:
detail.append(['Exist', exist.id, exist.fail_reason])
return summary, detail return summary, detail
def _verifier_audit_for_day_ums(beginning, ending, exists_model, ums_offset): def _verifier_audit_for_day(beginning, ending, exists_model):
summary = {} base_query = Q(raw__when__gte=beginning, raw__when__lte=ending)
return _verified_audit_base(base_query, exists_model)
def _verifier_audit_for_day_ums(beginning, ending, exists_model, ums_offset):
# NOTE(apmelton): # NOTE(apmelton):
# This is the UMS query we're trying to match. # This is the UMS query we're trying to match.
# where ( # where (
@ -119,20 +108,7 @@ def _verifier_audit_for_day_ums(beginning, ending, exists_model, ums_offset):
Q(raw__when__gt=beginning + ums_offset, Q(raw__when__gt=beginning + ums_offset,
audit_period_beginning__lt=ending)) audit_period_beginning__lt=ending))
periodic_range = Q(audit_period_ending=(F('audit_period_beginning') + return _verified_audit_base(ums, exists_model)
(60*60*24)))
periodic_exists = exists_model.objects.filter(ums & periodic_range)
summary['periodic'] = _audit_for_exists(periodic_exists)
instant_range = Q(audit_period_ending__lt=(F('audit_period_beginning') +
(60*60*24)))
instant_exists = exists_model.objects.filter(ums & instant_range)
summary['instantaneous'] = _audit_for_exists(instant_exists)
failed_query = Q(status=exists_model.FAILED)
failed = exists_model.objects.filter(ums & failed_query)
detail = [['Exist', e.id, e.fail_reason] for e in failed]
return summary, detail
def get_previous_period(time, period_length): def get_previous_period(time, period_length):