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

search-logs
Some checks failed
Deploy on push / deploy (push) Failing after 19s
Details

Browse Source
This commit is contained in:
Untone 2024-02-29 14:24:53 +03:00
parent 5df82704b3
commit 7ad9b7919a
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
services/search.py
View File

@ -97,18 +97,20 @@ class SearchService:
async def check_index(self): async def check_index(self):
if self.client: if self.client:
if not self.client.indices.exists(index=self.index_name): if not self.client.indices.exists(index=self.index_name):
logger.debug(f' Новый индекс {self.index_name}')
self.create_index() self.create_index()
logger.debug(f' Разметка индекации {self.index_name}')
self.client.indices.put_mapping( self.client.indices.put_mapping(
index=self.index_name, body=expected_mapping index=self.index_name, body=expected_mapping
) )
else: else:
logger.debug(f' Существующий индекс {self.index_name}')
# Check if the mapping is correct, and recreate the index if needed # Check if the mapping is correct, and recreate the index if needed
mapping = self.client.indices.get_mapping(index=self.index_name) mapping = self.client.indices.get_mapping(index=self.index_name)
if mapping != expected_mapping: if mapping != expected_mapping:
await self.recreate_index() await self.recreate_index()
async def recreate_index(self): async def recreate_index(self):
logger.debug(' Пересоздание индексов...')
async with asyncio.Lock(): async with asyncio.Lock():
self.delete_index() self.delete_index()
await self.check_index() await self.check_index()