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

lock-more-fix
All checks were successful
Deploy to core / deploy (push) Successful in 1m39s
Details

Browse Source
This commit is contained in:
Untone 2024-01-29 11:01:04 +03:00
parent 133067d09a
commit 98b379c8e1
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
services/search.py
View File

@ -50,7 +50,13 @@ class SearchService:
# ca_certs = ca_certs_path # ca_certs = ca_certs_path
) )
logger.info(' Клиент OpenSearch.org подключен') logger.info(' Клиент OpenSearch.org подключен')
if self.lock.acquire(blocking=False):
try:
self.check_index() self.check_index()
finally:
self.lock.release()
else:
logger.debug(' проверка пропущена')
except Exception as exc: except Exception as exc:
logger.error(f' {exc}') logger.error(f' {exc}')
self.client = None self.client = None
@ -63,6 +69,7 @@ class SearchService:
def delete_index(self): def delete_index(self):
if self.client: if self.client:
logger.debug(f' Удаляем индекс {self.index_name}')
self.client.indices.delete(index=self.index_name, ignore_unavailable=True) self.client.indices.delete(index=self.index_name, ignore_unavailable=True)
def create_index(self): def create_index(self):
@ -126,6 +133,7 @@ class SearchService:
} }
} }
if self.client: if self.client:
logger.debug(f' Разметка индекации {self.index_name}')
self.client.indices.put_mapping(index=self.index_name, body=mapping) self.client.indices.put_mapping(index=self.index_name, body=mapping)
def check_index(self): def check_index(self):
@ -149,9 +157,6 @@ class SearchService:
def recreate_index(self): def recreate_index(self):
if self.lock.acquire(blocking=False): if self.lock.acquire(blocking=False):
try: try:
logger.debug(
f' Удаляем индекс {self.index_name} из-за неправильной структуры данных'
)
self.delete_index() self.delete_index()
self.check_index() self.check_index()
finally: finally: