请问各位大神,以下错误应该如何解决
raise BulkIndexError('%i document(s) failed to index.' % len(errors), errors) elasticsearch.helpers.BulkIndexError: ('323 document(s) failed to index.', [{'index': {'_type': 'test', 'status': 500, '_index': 'test_20171125', 'error': {'type': 'node_not_connected_exception', 'reason': ' [es05] Node not connected'}, '_id': 'AV_7wXDrEDkyoJWf3qhF'}},
python api 灌库动作如下:
....
actions.append(action)
# 每1完条批量导入一次
if len(actions) == 30000:
# helper批量导入
for i in helpers.parallel_bulk(es, actions,
thread_count=6,
chunk_size=5000):
pass
actions = []
raise BulkIndexError('%i document(s) failed to index.' % len(errors), errors) elasticsearch.helpers.BulkIndexError: ('323 document(s) failed to index.', [{'index': {'_type': 'test', 'status': 500, '_index': 'test_20171125', 'error': {'type': 'node_not_connected_exception', 'reason': ' [es05] Node not connected'}, '_id': 'AV_7wXDrEDkyoJWf3qhF'}},
python api 灌库动作如下:
....
actions.append(action)
# 每1完条批量导入一次
if len(actions) == 30000:
# helper批量导入
for i in helpers.parallel_bulk(es, actions,
thread_count=6,
chunk_size=5000):
pass
actions = []
0 个回复