From acaf299bcb34462457bd1339f6cb671770208f9f Mon Sep 17 00:00:00 2001 From: Jack Robison Date: Mon, 30 Aug 2021 12:30:38 -0400 Subject: [PATCH] log time to update and decay trending in elasticsearch --- lbry/wallet/server/db/elasticsearch/search.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/lbry/wallet/server/db/elasticsearch/search.py b/lbry/wallet/server/db/elasticsearch/search.py index 7d933f036..ec8677d44 100644 --- a/lbry/wallet/server/db/elasticsearch/search.py +++ b/lbry/wallet/server/db/elasticsearch/search.py @@ -1,4 +1,4 @@ -import math +import time import asyncio import struct from binascii import unhexlify @@ -167,6 +167,8 @@ class SearchIndex: } ctx._source.trending_score_change = 0.0; """ + + start = time.perf_counter() await self.sync_client.update_by_query( self.index, body={ 'query': { @@ -175,6 +177,7 @@ class SearchIndex: 'script': {'source': update_trending_score_script, 'lang': 'painless'} }, slices=4, conflicts='proceed' ) + self.logger.info("updated trending scores in %ims", int((time.perf_counter() - start) * 1000)) whale_decay_factor = 2 * (2.0 ** (-1 / self._trending_whale_half_life)) decay_factor = 2 * (2.0 ** (-1 / self._trending_half_life)) @@ -188,12 +191,14 @@ class SearchIndex: ctx._source.trending_score *= %s; } """ % (self._trending_whale_threshold, whale_decay_factor, decay_factor) + start = time.perf_counter() await self.sync_client.update_by_query( self.index, body={ 'query': {'bool': {'must_not': [{'match': {'trending_score': 0.0}}]}}, 'script': {'source': decay_script, 'lang': 'painless'} }, slices=4, conflicts='proceed' ) + self.logger.info("decayed trending scores in %ims", int((time.perf_counter() - start) * 1000)) async def apply_filters(self, blocked_streams, blocked_channels, filtered_streams, filtered_channels): if filtered_streams: