Added some statsd counters for sync process

This commit is contained in:
M1ha 2018-12-19 12:21:28 +05:00
parent 38db27626c
commit 6c9e217161

View File

@ -195,6 +195,7 @@ class ClickHouseModel(with_metaclass(ClickHouseModelMeta, InfiModel)):
with statsd.timer(statsd_key.format('steps.get_operations')):
operations = storage.get_operations(import_key, cls.get_sync_batch_size())
statsd.incr(statsd_key.format('operations', count=len(operations)))
if operations:
with statsd.timer(statsd_key.format('steps.get_sync_objects')):
@ -202,6 +203,8 @@ class ClickHouseModel(with_metaclass(ClickHouseModelMeta, InfiModel)):
else:
import_objects = []
statsd.incr(statsd_key.format('import_objects', count=len(import_objects)))
if import_objects:
with statsd.timer(statsd_key.format('steps.get_insert_batch')):
batch = cls.get_insert_batch(import_objects)