اتصال به دیتابیس ElasticSearch در برنامه‌های Django

pip install elasticsearch

 # other codes ...
ELASTICSEARCH_DSL = {
    'default': {
        'hosts': os.getenv("ELASTICSEARCH_URI"),
    },
}
# other codes ...

ELASTICSEARCH_URI=http://elastic:G4bqHLMHvZKMscUy8OhLomK1@bromo.liara.cloud:328

pip freeze > requirements.txt

python manage.py startapp elasticsearch_app

# Application definition

INSTALLED_APPS = [
    'django.contrib.admin',
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.messages',
    'django.contrib.staticfiles',
    'elasticsearch_app', # add this
]

from elasticsearch import Elasticsearch
from django.conf import settings

class ElasticModel:
    def __init__(self):
        self.client = Elasticsearch(settings.ELASTICSEARCH_DSL['default']['hosts'])
        self.index = 'test_index'

    def create_index(self):
        if not self.client.indices.exists(index=self.index):
            self.client.indices.create(index=self.index)

    def insert_data(self, data):
        self.client.index(index=self.index, document=data)

    def read_data(self):
        response = self.client.search(index=self.index, body={"query": {"match_all": {}}})
        return response['hits']['hits']

from django.http import JsonResponse
from .elastic_model import ElasticModel

def elasticsearch_insert_read(request):
    es_model = ElasticModel()
    es_model.create_index()
    
    # Insert data
    data = {
        'name': 'Sample Data',
        'description': 'This is a sample data entry for Elasticsearch.'
    }
    es_model.insert_data(data)
    
    # Read data
    results = es_model.read_data()
    
    return JsonResponse(results, safe=False)

from django.urls import path
from .views import elasticsearch_insert_read

urlpatterns = [
    path('', elasticsearch_insert_read, name='elasticsearch_insert_read'),
]

from django.urls import include, path

urlpatterns = [
   
    path('elasticsearch/', include('elasticsearch_app.urls')),
]