mirror of
https://github.com/josejuanmartinez/libreCatastro.git
synced 2024-06-13 04:04:37 +02:00
92 lines
3.0 KiB
Python
92 lines
3.0 KiB
Python
from elasticsearch import Elasticsearch
|
|
|
|
from src.utils.cadastro_logger import CadastroLogger
|
|
|
|
logger = CadastroLogger(__name__).logger
|
|
|
|
|
|
class ElasticSearchUtils:
|
|
"""Custom class for managing Elastic Searcher queries"""
|
|
|
|
def __init__(self):
|
|
pass
|
|
|
|
@staticmethod
|
|
def create_index():
|
|
ElasticSearchUtils.remove_index()
|
|
es = Elasticsearch()
|
|
request_body = {
|
|
"settings": {
|
|
"number_of_shards": 5,
|
|
"number_of_replicas": 1
|
|
},
|
|
|
|
"mappings": {
|
|
"cadaster_doc": {
|
|
"properties": {
|
|
"location": {
|
|
"type": "geo_point"
|
|
},
|
|
"constructions": {
|
|
"type": "nested",
|
|
"properties":
|
|
{
|
|
"door": "keyword",
|
|
"doorway": "keyword",
|
|
"floor": "keyword",
|
|
"reform": {
|
|
"type": "nested",
|
|
"properties":
|
|
{
|
|
"type": "keyword",
|
|
"year": "keyword"
|
|
}
|
|
},
|
|
"surface": "keyword",
|
|
"use": "keyword"
|
|
}
|
|
}
|
|
},
|
|
"dynamic_templates": [
|
|
{
|
|
"strings": {
|
|
"match_mapping_type": "string",
|
|
"mapping": {
|
|
"type": "text",
|
|
"fields": {
|
|
"keyword": {
|
|
"type": "keyword"
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
]
|
|
},
|
|
}
|
|
}
|
|
logger.debug("Creating 'cadaster' index...")
|
|
res = es.indices.create(index='cadaster', body=request_body)
|
|
logger.debug(res)
|
|
|
|
@staticmethod
|
|
def remove_index():
|
|
es = Elasticsearch()
|
|
logger.debug("Deleting 'cadaster' index...")
|
|
res = es.indices.delete(index='cadaster', ignore=[400, 404])
|
|
logger.debug(res)
|
|
|
|
@staticmethod
|
|
def create_index_companies():
|
|
es = Elasticsearch()
|
|
request_body = {
|
|
"settings": {
|
|
"number_of_shards": 5,
|
|
"number_of_replicas": 1
|
|
},
|
|
}
|
|
logger.debug("Creating 'borme' index...")
|
|
res = es.indices.create(index='borme', body=request_body)
|
|
logger.debug(res)
|
|
|