carrotquest/django-clickhouse
1
1
Fork 0
mirror of https://github.com/carrotquest/django-clickhouse.git synced 2025-06-05 13:43:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

Measure time for inserting tuples

Browse Source
This commit is contained in:
M1ha 2019-02-05 15:13:15 +05:00
parent df422d11f1
commit ef6fc46c5c
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/django_clickhouse/database.py
View File

@ -113,10 +113,11 @@ class Database(InfiDatabase):
# Return any remaining lines in partial batch # Return any remaining lines in partial batch
if lines: if lines:
statsd.incr(statsd_key.format('insert_batch'), count=lines) statsd.incr(statsd_key, lines)
yield buf.getvalue() yield buf.getvalue()
self._send(gen()) with statsd.timer(statsd_key):
self._send(next(gen()))
class ConnectionProxy: class ConnectionProxy:

2
tests/clickhouse_models.py
View File

@ -27,7 +27,7 @@ class ClickHouseCollapseTestModel(ClickHouseModel):
id = fields.Int32Field() id = fields.Int32Field()
created = fields.DateTimeField() created = fields.DateTimeField()
value = fields.Int32Field() value = fields.Int32Field()
sign = fields.Int8Field() sign = fields.Int8Field(default=1)
version = fields.Int8Field(default=1) version = fields.Int8Field(default=1)
engine = CollapsingMergeTree('created', ('id',), 'sign') engine = CollapsingMergeTree('created', ('id',), 'sign')