当我尝试用bulk_indexing()进程索引它时,它会停止在某些索引上。我改了heap_size in jvm.options --没什么用。
这是输出: 产品489索引产品490索引产品491索引产品492索引产品493索引产品494索引产品495索引产品496索引产品496索引产品498索引产品498索引产品2280索引后bulk状态:n/A请求:0.001s回溯(最近一次调用):File“,第1行,在文件"/code/products/documents.py",第93行,在bulk_indexing批量(client=es,文件"/usr/local/lib/python3.6/site-packages/elasticsearch/helpers/__init__.py",行257,大容量表示ok,项目在streaming_bulk(client,actions,**kwargs):文件"/usr/local/lib/python3.6/site-packages/elasticsearch/helpers/__init__.py",第192行,在streaming_bulk raise_on_error中**kwargs)文件"/usr/local/lib/python3.6/site-packages/elasticsearch/helpers/__init__.py",第99行,_process_bulk_chunk提出e文件"/usr/local/lib/python3.6/site-packages/elasticsearch/helpers/__init__.py",第95行,_process_bulk_chunk resp =client.bulk(‘\n’..join(Bulk_actions)+ '\n',**kwargs)文件"/usr/local/lib/python3.6/site-packages/elasticsearch/client/utils.py",第76行,在_wrapped返回函数中(*args,params=params,**kwargs)文件"/usr/local/lib/python3.6/site-packages/elasticsearch/client/__init__.py",行1150,在大容量文件{‘content-type’:‘application/x-ndjson’}中,文件"/usr/local/lib/python3.6/site-packages/elasticsearch/transport.py",第314行,在perform_request状态中,headers_response,data =connection.perform_request(方法、url、params、body、headers=headers、ignore=ignore、timeout=timeout)文件"/usr/local/lib/python3.6/site-packages/elasticsearch/connection/http_urllib3.py",第175行,在perform_request raise (‘N/A’,str( e),e) ConnectionError(:未能建立新连接: Errno 111连接被拒绝)由: NewConnectionError(:未能建立新连接: Errno 111连接被拒绝)
发布于 2018-11-14 10:30:58
问题在于块状的大小。是default=500写的。我扩大了规模,解决了我的问题。
https://stackoverflow.com/questions/53283436
复制相似问题