mirrors/syncstorage-rs
1
0
Fork 0
mirror of https://github.com/mozilla-services/syncstorage-rs.git synced 2026-05-12 16:16:36 +02:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

purg_ttl.py pep8

Browse Source
This commit is contained in:
Erik Olson 2020-01-07 21:52:51 -05:00
parent 74b95544b0
commit c8134fda4a
No known key found for this signature in database
GPG Key ID: BB933F02985A125E
1 changed files with 10 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tools/spanner/purge_ttl.py
View File

@ -14,8 +14,10 @@ from urllib import parse
from google.cloud import spanner
# set up logger
logging.basicConfig(format='{"datetime": "%(asctime)s", "message": "%(message)s"}',
stream=sys.stdout,level=logging.INFO)
logging.basicConfig(
format='{"datetime": "%(asctime)s", "message": "%(message)s"}',
stream=sys.stdout,
level=logging.INFO)
# Change these to match your install.
client = spanner.Client()
@ -53,7 +55,8 @@ def spanner_read_data(request=None):
query = 'DELETE FROM batches WHERE expiry < CURRENT_TIMESTAMP()'
result = database.execute_partitioned_dml(query)
batches_end = datetime.now()
logging.info("batches: removed {} rows, batches_duration: {}".format(result, batches_end - batches_start))
logging.info("batches: removed {} rows, batches_duration: {}".format(
result, batches_end - batches_start))
# Delete BSOs
with statsd.timer("syncstorage.purge_ttl.bso_duration"):
@ -61,7 +64,8 @@ def spanner_read_data(request=None):
query = 'DELETE FROM bsos WHERE expiry < CURRENT_TIMESTAMP()'
result = database.execute_partitioned_dml(query)
bso_end = datetime.now()
logging.info("bso: removed {} rows, bso_duration: {}".format(result, bso_end - bso_start))
logging.info("bso: removed {} rows, bso_duration: {}".format(
result, bso_end - bso_start))
if __name__ == "__main__":
@ -73,4 +77,5 @@ if __name__ == "__main__":
end_time = datetime.now()
duration = end_time - start_time
logging.info('Completed purge_ttl.py, total_duration: {}'.format(duration))
logging.info(
'Completed purge_ttl.py, total_duration: {}'.format(duration))