pythonapielasticsearch_elasticsearchpython批量api（elasticsearchpy）

我的代码&＃xff1a;from elasticsearch import Elasticsearch

es &＃61; Elasticsearch()

doc &＃61; &＃39;&＃39;&＃39;\n {"host":"logsqa","path":"/logs","message":"test test","&＃64;timestamp":"2014-10-02T10:11:25.980256","tags":["multiline","mydate_0.005"]} \n&＃39;&＃39;&＃39;

result &＃61; es.bulk(index&＃61;"logstash-test", doc_type&＃61;"test", body&＃61;doc)

错误是&＃xff1a;No handlers could be found for logger "elasticsearch"

Traceback (most recent call last):

File "./log-parser-perf.py", line 55, in

insertToES()

File "./log-parser-perf.py", line 46, in insertToES

res &＃61; es.bulk(index&＃61;"logstash-test", doc_type&＃61;"test", body&＃61;doc)

File "/usr/local/lib/python2.7/dist-packages/elasticsearch-1.0.0-py2.7.egg/elasticsearch/client/utils.py", line 70, in _wrapped

return func(*args, params&＃61;params, **kwargs)

File "/usr/local/lib/python2.7/dist-packages/elasticsearch-1.0.0-py2.7.egg/elasticsearch/client/__init__.py", line 570, in bulk

params&＃61;params, body&＃61;self._bulk_body(body))

File "/usr/local/lib/python2.7/dist-packages/elasticsearch-1.0.0-py2.7.egg/elasticsearch/transport.py", line 274, in perform_request

status, headers, data &＃61; connection.perform_request(method, url, params, body, ignore&＃61;ignore)

File "/usr/local/lib/python2.7/dist-packages/elasticsearch-1.0.0-py2.7.egg/elasticsearch/connection/http_urllib3.py", line 57, in perform_request

self._raise_error(response.status, raw_data)

File "/usr/local/lib/python2.7/dist-packages/elasticsearch-1.0.0-py2.7.egg/elasticsearch/connection/base.py", line 83, in _raise_error

raise HTTP_EXCEPTIONS.get(status_code, TransportError)(status_code, error_message, additional_info)

elasticsearch.exceptions.TransportError: TransportError(500, u&＃39;ActionRequestValidationException[Validation Failed: 1: no requests added;]&＃39;)

为POST call生成的url是/logstash-test/test/_bulk

柱体是&＃xff1a;{"host":"logsqa","path":"/logs","message":"test

test","&＃64;timestamp":"2014-10-02T10:11:25.980256","tags":["multiline","mydate_0.005"]}

所以我用手把车卷起来&＃xff1a;

这种卷曲不起作用&＃xff1a;> curl -XPUT http://localhost:9200/logstash-test/test2/_bulk -d

> &＃39;{"host":"logsqa","path":"/logs","message":"test

> test","&＃64;timestamp":"2014-10-02T10:11:25.980256","tags":["multiline","mydate_0.005"]}

> &＃39;

>

> {"error":"ActionRequestValidationException[Validation Failed: 1: no requests added;]","status":500}

所以错误是部分正常的&＃xff0c;但是我确实希望elasticsearch.bulk()能够正确地管理输入参数。

pythonf函数是&＃xff1a;bulk(*args, **kwargs)

:arg body: The operation definition and data (action-data pairs), as

either a newline separated string, or a sequence of dicts to

serialize (one per row).

:arg index: Default index for items which don&＃39;t provide one

:arg doc_type: Default document type for items which don&＃39;t provide one

:arg consistency: Explicit write consistency setting for the operation

:arg refresh: Refresh the index after performing the operation

:arg routing: Specific routing value

:arg replication: Explicitly set the replication type (default: sync)

:arg timeout: Explicit operation timeout