mirror of
https://github.com/nikdoof/test-auth.git
synced 2025-12-14 06:42:16 +00:00
Added task to clean-up old API access logs
This commit is contained in:
@@ -1,3 +1,4 @@
|
||||
from django.conf import settings
|
||||
import logging
|
||||
from datetime import datetime, timedelta
|
||||
from celery.decorators import task
|
||||
@@ -8,5 +9,16 @@ def clear_stale_cache(cache_extension=0):
|
||||
log = clear_stale_cache.get_logger()
|
||||
|
||||
time = datetime.utcnow() - timedelta(seconds=cache_extension)
|
||||
objs = CachedDocument.objects.filter(cached_until__lt=datetime.utcnow()).delete()
|
||||
self.log.info('Removed %s stale cache documents' % objs.count())
|
||||
objs = CachedDocument.objects.filter(cached_until__lt=time)
|
||||
log.info('Removing %s stale cache documents' % objs.count())
|
||||
objs.delete()
|
||||
|
||||
|
||||
@task(ignore_result=True)
|
||||
def clear_old_logs():
|
||||
log = clear_old_logs.get_logger()
|
||||
|
||||
time = datetime.utcnow() - timedelta(day=settings.EVE_PROXY_KEEP_LOGS)
|
||||
objs = ApiAccessLog.objects.filter(time_access__lt=time)
|
||||
log.info('Removing %s old access logs' % objs.count())
|
||||
objs.delete()
|
||||
|
||||
Reference in New Issue
Block a user