@classmethod
    def index_data(cls, documents, id_field='id'):
        documents = (dict(d, _id=d[id_field]) for d in documents)
        bulk_index(cls.get_es(), documents, index=cls.index_name,
                   doc_type=cls.mapping_type_name)
        cls.refresh()
Get a message from the iopub channel
dataset/ETHPy150Open mozilla/elasticutils/elasticutils/estestcase.py/ESTestCase.index_data--crossover with--dataset/ETHPy150Open jupyter/jupyter_client/jupyter_client/client.py/KernelClient.get_iopub_msg