Tengo que almacenar algún mensaje en ElasticSearch para integrarlo con mi programa python. Ahora lo que trato de almacenar el mensaje es:

d={"message":"this is message"}
    for index_nr in range(1,5):
        ElasticSearchAPI.addToIndex(index_nr, d)
        print d

Eso significa que si tengo 10 mensajes, entonces tengo que repetir mi código 10 veces. Entonces, lo que quiero hacer es intentar hacer un archivo de script o un archivo por lotes. He comprobado elGuía de ElasticSearch, Es posible usar BULK API. El formato debe ser algo como a continuación:

{ "index" : { "_index" : "test", "_type" : "type1", "_id" : "1" } }
{ "field1" : "value1" }
{ "delete" : { "_index" : "test", "_type" : "type1", "_id" : "2" } }
{ "create" : { "_index" : "test", "_type" : "type1", "_id" : "3" } }
{ "field1" : "value3" }
{ "update" : {"_id" : "1", "_type" : "type1", "_index" : "index1"} }
{ "doc" : {"field2" : "value2"} }

Lo que hice es:

{"index":{"_index":"test1","_type":"message","_id":"1"}}
{"message":"it is red"}
{"index":{"_index":"test2","_type":"message","_id":"2"}}
{"message":"it is green"}

También utilizo la herramienta de rizo para almacenar el documento.

$ curl -s -XPOST localhost:9200/_bulk --data-binary @message.json

Ahora quiero usarmi código de Python para almacenar el archivo en la Búsqueda Elástica.