trans2es_mapping2es.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-

from django.conf import settings
from django.core.management.base import BaseCommand, CommandError
import traceback
import logging
from libs.es import ESPerform


class Command(BaseCommand):

    def handle(self, *args, **options):
        try:
            es_obj = ESPerform()
            es_cli = es_obj.get_cli()

            es_obj.create_index(es_cli,"diary")
            es_obj.put_index_mapping(es_cli,"diary")
        except:
            logging.error("catch exception,err_msg:%s" % traceback.format_exc())