小编RCP*_*RCP的帖子

从python脚本我将数据发送到elasticsearch服务器

这将帮助我连接到 ES

es = Elasticsearch('localhost:9200',use_ssl=False,verify_certs=True)

通过使用波纹管代码，我可以将所有数据发送到我的本地 ES 服务器

es.index(index='alertnagios', doc_type='nagios', body=jsonvalue) 

但是，当我尝试将数据发送到云 ES 服务器时，脚本执行良好，并且在索引几个文档后索引了几个文档我收到以下错误

Traceback (most recent call last):
  File "scriptfile.py", line 78, in <module>
    es.index(index='test', doc_type='test123', body=jsonvalue) 
  File "/usr/local/lib/python2.7/dist-packages/elasticsearch/client/utils.py", line 73, in _wrapped
    return func(*args, params=params, **kwargs)
  File "/usr/local/lib/python2.7/dist-packages/elasticsearch/client/__init__.py", line 298, in index
    _make_path(index, doc_type, id), params=params, body=body)
  File "/usr/local/lib/python2.7/dist-packages/elasticsearch/transport.py", line 342, in perform_request
    data = self.deserializer.loads(data, headers.get('content-type'))
  File "/usr/local/lib/python2.7/dist-packages/elasticsearch/serializer.py", line 76, in loads
    return deserializer.loads(s)
  File "/usr/local/lib/python2.7/dist-packages/elasticsearch/serializer.py", line 40, in loads
    raise SerializationError(s, e)
elasticsearch.exceptions.SerializationError: (u'order=0></iframe>', JSONDecodeError('No …

我有将近1万个json文档，我想通过使用来自python的elasticsearch bulk api将所有这些文档推送到elasticsearch。我浏览了一些文档，但没有任何解决方案。

result=es.bulk(index="index1", doc_type="index123", body=jsonvalue)
helpers.bulk(es,doc) 

我都尝试了两次，但没有结果，我收到此错误

elasticsearch.exceptions.RequestError: TransportError(400, u'illegal_argument_exception', u'Malformed action/metadata line [1], expected START_OBJECT or END_OBJECT but found [VALUE_STRING]')

请帮我