elasticsearch 대량 인덱스 데이터
1563 단어 elasticsearch
다음 대량 색인 코드:
Settings settings=ImmutableSettings.settingsBuilder()
.put("client.transport.sniff",true).put("cluster.name","myelasticsearch").build();
// transport
Client client=new TransportClient(settings).addTransportAddress(
new InetSocketTransportAddress("192.168.1.100",9300));
//
BulkRequestBuilder bulkRequest=client.prepareBulk();
while(rs.next()){
// json
bulkRequest.add(client.prepareIndex("ryxx","tweet",rs.getString("id")).setSource(jsonBuilder().startObject()
.field("name",rs.getString("name"))
.field("age",rs.getString("age"))
.field("address",rs.getString("address"))
.field("phone",rs.getString("phone"))
.endObject()
));
}
//
BulkResponse bulkResponse=bulkRequest.execute().actionGet();
//
if(bulkResponse.hasFailures()){
System.out.println(bulkResponse.buildFailureMessage());
}데이터 제출 속도는 데이터베이스 조회 속도, 기계 설정 등과 관련이 있고 집단이라면 네트워크 대역폭과 관련이 있다.그리고 내 설정: index.number_of_shards:5 즉 5개의 분할 인덱스.number_of_replics:1 즉, 조각마다 백업이 있습니다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
kafka connect e elasticsearch를 관찰할 수 있습니다.No menu lateral do dashboard tem a opção de connectors onde ele mostra todos os clusters do kafka connect conectados atu...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.
좋은 웹페이지 즐겨찾기
