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

search-thread-2

Browse Source
This commit is contained in:
Untone 2024-02-29 13:49:34 +03:00
parent b4f86526a2
commit 14c2750d92
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
services/search.py
View File

@ -1,5 +1,6 @@
import json import json
import os import os
from multiprocessing import Manager
import threading import threading
from opensearchpy import OpenSearch from opensearchpy import OpenSearch
@ -38,8 +39,9 @@ index_settings = {
'properties': { 'properties': {
'body': {'type': 'text', 'analyzer': 'ru'}, 'body': {'type': 'text', 'analyzer': 'ru'},
'title': {'type': 'text', 'analyzer': 'ru'}, 'title': {'type': 'text', 'analyzer': 'ru'},
'lead': {'type': 'text', 'analyzer': 'ru'},
'subtitle': {'type': 'text', 'analyzer': 'ru'}, 'subtitle': {'type': 'text', 'analyzer': 'ru'},
'lead': {'type': 'text', 'analyzer': 'ru'},
# 'author': {'type': 'text'},
} }
}, },
} }
@ -50,10 +52,12 @@ expected_mapping = index_settings['mappings']
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
self.manager = Manager()
self.client = None self.client = None
# Используем менеджер для создания Lock и Value # Используем менеджер для создания Lock и Value
self.lock = threading.Lock() self.lock = threading.Lock()
self.initialized_flag = self.manager.Value('i', 0)
# Only initialize the instance if it's not already initialized # Only initialize the instance if it's not already initialized
if not self.initialized_flag.value and ELASTIC_HOST: if not self.initialized_flag.value and ELASTIC_HOST: