def initialize(self, conf, ctx):
        """Initialization steps:

        1. Prepare elasticsearch connection, including details for indexing.
        """
        config = get_config()['ElasticsearchIndexBolt']
        elasticsearch_class = import_name(config['elasticsearch_class'])
        self.es = elasticsearch_class(**config['elasticsearch_init'])
        self.index = config['index']
        self.doc_type = config['doc_type']
def initialize ( self , conf , ctx ) : config = get_config ( ) [ 'ElasticsearchIndexBolt' ] elasticsearch_class = import_name ( config [ 'elasticsearch_class' ] ) self . es = elasticsearch_class ( ** config [ 'elasticsearch_init' ] ) self . index = config [ 'index' ] self . doc_type = config [ 'doc_type' ]
Initialization steps:

        1. Prepare elasticsearch connection, including details for indexing.