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

indexing-fix-3

Browse Source
This commit is contained in:
Untone 2024-02-29 14:09:50 +03:00
parent f07fd646d3
commit ca3065f741
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
services/search.py
View File

@ -46,6 +46,10 @@ index_settings = {
expected_mapping = index_settings['mappings'] expected_mapping = index_settings['mappings']
# Create an event loop
search_loop = asyncio.get_event_loop()
class SearchService: class SearchService:
def __init__(self, index_name='search_index'): def __init__(self, index_name='search_index'):
self.index_name = index_name self.index_name = index_name
@ -65,7 +69,9 @@ class SearchService:
# ca_certs = ca_certs_path # ca_certs = ca_certs_path
) )
logger.info(' Клиент OpenSearch.org подключен') logger.info(' Клиент OpenSearch.org подключен')
asyncio.create_task(self.check_index())
# Create a task and run it in the event loop
search_loop.create_task(self.check_index())
except Exception as exc: except Exception as exc:
logger.error(f' {exc}') logger.error(f' {exc}')
self.client = None self.client = None
@ -133,8 +139,10 @@ class SearchService:
await redis.execute('SETEX', redis_key, REDIS_TTL, json.dumps(results)) await redis.execute('SETEX', redis_key, REDIS_TTL, json.dumps(results))
return [] return []
search_service = SearchService() search_service = SearchService()
async def search_text(text: str, limit: int = 50, offset: int = 0): async def search_text(text: str, limit: int = 50, offset: int = 0):
payload = [] payload = []
if search_service.client: if search_service.client: