mygpo/search/index.py

   1
   2 """ Contains code for indexing other objects """
   3
   4 from pyes import ES
   5 from pyes.exceptions import IndexAlreadyExistsException
   6
   7 from django.conf import settings
   8
   9 import logging
  10 logger = logging.getLogger(__name__)
  11
  12
  13 def index_podcast(sender, **kwargs):
  14     print kwargs
  15
  16
  17 def create_index():
  18     """ Creates the Elasticsearch index """
  19     conn = ES(settings.ELASTICSEARCH_SERVER)
  20
  21     logger.info('Creating index %s' % settings.ELASTICSEARCH_INDEX)
  22     try:
  23         conn.indices.create_index(settings.ELASTICSEARCH_INDEX)
  24
  25     except IndexAlreadyExistsException as ex:
  26         logger.info(str(ex))
  27