执行字符串操作时无法在elasticsearch中索引文档

Question

我必须在elasticsearch中索引存储在文件中的文档，我在索引文档的同时对其执行字符串操作。（我必须对线路进行分区，并单独使用拆分）

rec = open(file)

for line in rec:

    val_1 = line.partition(' ')[0].strip()
    val_2 = line.partition(' ')[1].strip()
    #print   str(val_1) + " " + str(val_2)
    es.index(index="test", doc_type="trial", id = val_1, body = val2)

我可以打印这行，但由于某种原因无法索引它。它抛出以下错误。

文件“C:\Python27\lib\site packages\elasticsearch\client\utils.py”，第69行，in

文件"C：\Python27\lib\site-pack\elasticsearch\client__init__. py"，行

文件“C:\Python27\lib\site packages\elasticsearch\transport.py”，第307行，in

如果我在循环内执行这些操作，这个错误是相同的

es.index(index = "test", doc_type= "trial", id = line.partition(' ')[0].strip(), body = line.partition(' ')[2].strip())

我是否以错误的方式发送参数？我应该从哪里着手解决这个问题。

Answer 1

我找到了解决办法：这真是一个愚蠢的错误。我写的是

es.index(index="test", doc_type="trial", id = val_1, body = val2)

我错过的是正确的身体格式。应该是

es.index(index="test", doc_type="trial", id = val_1, body = {"name": val2 } )