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

no-delete-index

Browse Source
This commit is contained in:
Untone 2024-05-18 11:32:30 +03:00
parent be6d2454b1
commit 3d8e484187
1 changed files with 3 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
services/search.py
View File

@ -91,7 +91,7 @@ class SearchService:
def delete_index(self): def delete_index(self):
if self.client: if self.client:
logger.debug(f"Удаляем индекс {self.index_name}") logger.warning(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):
@ -119,22 +119,11 @@ class SearchService:
mapping = result.get(self.index_name, {}).get("mappings") mapping = result.get(self.index_name, {}).get("mappings")
if mapping and mapping != expected_mapping: if mapping and mapping != expected_mapping:
logger.debug(f"Найдена структура индексации: {mapping}") logger.debug(f"Найдена структура индексации: {mapping}")
logger.warn( logger.warn("[!!!] Требуется другая структура индексации и переиндексация данных")
"Требуется другая структура индексации, переиндексация" self.client = None
)
await self.recreate_index()
else: else:
logger.error("клиент не инициализован, невозможно проверить индекс") logger.error("клиент не инициализован, невозможно проверить индекс")
async def recreate_index(self):
if self.client:
async with self.lock:
self.client.indices.delete(
index=self.index_name, ignore_unavailable=True
)
await self.check_index()
else:
logger.error("клиент не инициализован, невозможно пересоздать индекс")
def index(self, shout): def index(self, shout):
if self.client: if self.client: