def __init__(self):
        super(Database, self).__init__()
        self.name = self.CONFIG.DATA_HUB_DB_DATABASE
        self.host = self.CONFIG.HUB_DB_BACKEND["host"]
        self.client = Elasticsearch(self.host, serializer=_HubDBEncoder())

        if not self.client.indices.exists(index=self.name):
            self.client.indices.create(index=self.name, body={
                'settings': {
                    'number_of_shards': 1,
                    "number_of_replicas": 0,
                },
                'mappings': {
                    "enabled": False
                }
            })