0

试图让批量渗透功能适用于 Elasticsearch-py(即渗透),但无法在线找到示例。我可以使用 percolate 函数,所以我可以让它工作:

doc = {'doc' : {'field1' : 'this is a value', 'field2' : 'this is another value'}}
res = es.percolate(index = 'my_index', doc_type = 'my_doc_type', body = doc)

到目前为止,我阅读的文档似乎暗示,如果我想进行批量提交,我需要将标题和正文作为字符串发送,并用换行符分隔。因此,我尝试过:

head = {'percolate' : {'index' : 'my_index', 'type' : 'my_doc_type'}}    
doc = {'doc' : {'field1' : 'this is a value', 'field2' : 'this is another value'}}
doc2 = {'doc' : {'field1' : 'values and values', 'field2' : 'billions of values'}}

query_list = [head, doc, head, doc2]
my_body = '\n'.join([str(qry) for qry in query_list])

res = es.mpercolate(body = my_body)

这给了我一个通用的“elasticsearch.exceptions.TransportError”。有人有我可以适应的工作示例吗?

4

1 回答 1

0

您不必自己序列化数据,只需传入query_listas 正文,它应该做正确的事情

于 2017-04-25T16:39:58.940 回答