mongodb timeout 처리
This commit is contained in:
@@ -19,7 +19,9 @@ import org.springframework.data.mongodb.core.aggregation.AggregationResults;
|
|||||||
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import java.time.Duration;
|
||||||
import java.util.*;
|
import java.util.*;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
@Slf4j
|
@Slf4j
|
||||||
@Service
|
@Service
|
||||||
@@ -212,6 +214,7 @@ public class BusinessLogGenericService extends BusinessLogServiceBase {
|
|||||||
|
|
||||||
AggregationOptions options = AggregationOptions.builder()
|
AggregationOptions options = AggregationOptions.builder()
|
||||||
.allowDiskUse(true)
|
.allowDiskUse(true)
|
||||||
|
.maxTime(Duration.ofSeconds(600))
|
||||||
.build();
|
.build();
|
||||||
Aggregation aggregation = Aggregation.newAggregation(operations).withOptions(options);
|
Aggregation aggregation = Aggregation.newAggregation(operations).withOptions(options);
|
||||||
log.info("loadBusinessLogData Generic Query: {}", aggregation);
|
log.info("loadBusinessLogData Generic Query: {}", aggregation);
|
||||||
|
|||||||
Reference in New Issue
Block a user