performance es index bug修复

liangliang 5 years ago
parent fa7fcc36de
commit 3b5c50c5a1

@ -92,7 +92,15 @@ class ElapsedTimeDocument(Document):
doc_type = 'ElapsedTime'
class ElaspedTimeDocumentManager():
class ElaspedTimeDocumentManager:
@staticmethod
def build_index():
from elasticsearch import Elasticsearch
client = Elasticsearch(settings.ELASTICSEARCH_DSL['default']['hosts'])
res = client.indices.exists(index="performance")
if not res:
ElapsedTimeDocument.init()
@staticmethod
def delete_index():
from elasticsearch import Elasticsearch
@ -101,12 +109,6 @@ class ElaspedTimeDocumentManager():
@staticmethod
def create(url, time_taken, log_datetime, useragent, ip):
from elasticsearch import Elasticsearch
client = Elasticsearch(settings.ELASTICSEARCH_DSL['default']['hosts'])
res = client.indices.exists(index="performance")
if not res:
ElapsedTimeDocument.init()
ua = UserAgent()
ua.browser = UserAgentBrowser()
ua.browser.Family = useragent.browser.family

@ -23,8 +23,8 @@ class Command(BaseCommand):
def handle(self, *args, **options):
if ELASTICSEARCH_ENABLED:
ElaspedTimeDocumentManager.build_index()
manager = ElapsedTimeDocument()
ElaspedTimeDocumentManager.delete_index()
manager.init()
manager = ArticleDocumentManager()
manager.delete_index()

Loading…
Cancel
Save