discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

bypass-fix
Some checks failed
Deploy to core / deploy (push) Has been cancelled
Details

Browse Source
This commit is contained in:
Untone 2024-01-29 06:51:26 +03:00
parent d595a18de4
commit 520b43ee48
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
services/search.py
View File

@ -99,13 +99,15 @@ class SearchService:
} }
try: try:
if self.client: if self.client:
with self.lock: if self.lock.acquire(blocking=False):
logger.debug(f' Создаём новый индекс: {self.index_name} ') logger.debug(f' Создаём новый индекс: {self.index_name} ')
self.client.indices.create( self.client.indices.create(
index=self.index_name, body=index_settings index=self.index_name, body=index_settings
) )
self.client.indices.close(index=self.index_name) self.client.indices.close(index=self.index_name)
self.client.indices.open(index=self.index_name) self.client.indices.open(index=self.index_name)
else:
logger.debug('..')
except Exception as error: except Exception as error:
logging.error(f' Ошибка поиска: {error}') logging.error(f' Ошибка поиска: {error}')
@ -139,12 +141,17 @@ class SearchService:
self.recreate_index() self.recreate_index()
def recreate_index(self): def recreate_index(self):
with self.lock: if self.lock.acquire(blocking=False):
logger.debug( try:
f' Пересоздаём индекс {self.index_name} из-за неправильной структуры данных' logger.debug(
) f' Удаляем индекс {self.index_name} из-за неправильной структуры данных'
self.delete_index() )
self.check_index() self.delete_index()
self.check_index()
finally:
self.lock.release()
else:
logger.debug(' ..')
def index(self, shout): def index(self, shout):
if self.client: if self.client: