Create an ElasticSearch instance, and given a list of documents, index the documents into ElasticSearch.

elastic_indexer.py

from elasticsearch.helpers import bulk
from elasticsearch import Elasticsearch

class ElasticIndexer(object):
    """
    Create an ElasticSearch instance, and given a list of documents, 
    index the documents into ElasticSearch.
    """
    def __init__(self):
        self.elastic_search = Elasticsearch()
        
    def make_documents(self, textdict):
        """
        A textdict is a dictionary of documents where each key corresponds
        to a document category and each value is a list of documents
        """
        for category, docs in textdict:
            for document in docs:
                yield {
                    "_index": category,
                    "_type": "_doc",
                    "description": document
                }        
                
    def index(self, textdict):
        bulk(self.elastic_search, self.make_documents(textdict))