code: def init(self):
          
          # ignore 400 (IndexAlreadyExistsException) when creating an index
          self.es.indices.create(index=self.params['index'], ignore=400)
docs: Create an Elasticsearch index if necessary