0

Google App Engine v. 1.9.48을 사용하고 있습니다. 일부 데이터 저장소 쿼리 중 무작위로 "CancellationException : 작업 취소됨"오류가 발생했습니다. 그리고 정확히이 오류의 원인을 정확히 알지 못합니다. other에서 Stackoverflow posts, 나는 이것이 막연하게 시간 제한과 관련이 있다는 것을 모호하지만 이해하지 못하고있다. TaskQueues를 사용하지 않고있다. 여기에 그 오류를 던지고있다Google 데이터 스토어 쿼리를 수행하는 동안 "CancellationException : 작업 취소됨"오류가 발생했습니다.

java.util.concurrent.CancellationException: Task was cancelled. 
    at com.google.common.util.concurrent.AbstractFuture.cancellationExceptionWithCause(AbstractFuture.java:1126) 
    at com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:504) 
    at com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:407) 
    at com.google.common.util.concurrent.AbstractFuture$TrustedFuture.get(AbstractFuture.java:86) 
    .... 
    at com.sun.proxy.$Proxy14.size(Unknown Source) 
    at main.java.com.continentalist.app.model.Model.getEntitySentimentCounts(Model.java:285) 
    at main.java.com.continentalist.app.model.Model.access$100(Model.java:37) 
    at main.java.com.continentalist.app.model.Model$2.vrun(Model.java:251) 
    at com.googlecode.objectify.VoidWork.run(VoidWork.java:14) 
    at com.googlecode.objectify.VoidWork.run(VoidWork.java:11) 
    at com.googlecode.objectify.ObjectifyService.run(ObjectifyService.java:81) 
    ... 

내 애플 리케이션 엔진 코드 :

다음은 스택 추적입니다. 나는 오류가 (일반적으로 list().size() 중 하나)에서 발생되는 줄 주석 추가 : 당신은 .list().size()를 호출 할 필요는 없습니다

private EntityAnalysis getEntitySentimentCounts(ComboCall comboCall) { 
     Query<ObjectifyArticle> queryArticles = ofy().load().type(ObjectifyArticle.class); 

     queryArticles = queryArticles.filter("domain", comboCall.getDomain()); 

     Set<Entity> entitySet = comboCall.getEntitySet(); 
     SentimentCount[] allSentimentCounts = new SentimentCount[entitySet.size()]; 
     int index = 0; 
     for(Entity eachEntity : entitySet) { 
      SentimentCount sentimentCount = new SentimentCount(); 
      String eachEntityName = eachEntity.getText(); 
      Query<ObjectifyArticle> newQuery = queryArticles; 
      newQuery = newQuery.filter("entityName", eachEntityName); 
      sentimentCount.setEntityName(eachEntityName); 

      Query<ObjectifyArticle> positiveFilter = newQuery; 
      positiveFilter = positiveFilter.filter("entityType", POSITIVE); 
      int positive = positiveFilter.list().size(); // ERROR EITHER HERE 
      sentimentCount.setPositiveCount(positive+""); 

      Query<ObjectifyArticle> negativeFilter = newQuery; 
      negativeFilter = negativeFilter.filter("entityType", NEGATIVE); 
      int negative = negativeFilter.list().size(); // OR HERE 
      sentimentCount.setNegativeCount(""+negative); 

      Query<ObjectifyArticle> neutralFilter = newQuery; 
      neutralFilter = neutralFilter.filter("entityType", NEUTRAL); 
      int neutral = neutralFilter.list().size(); // OR HERE 
      sentimentCount.setNeutralCount(""+neutral); 

      allSentimentCounts[index] = sentimentCount; 
      index++; 
     } 
     EntityAnalysis entityAnalysis = new EntityAnalysis(); 
     entityAnalysis.setDomain(comboCall.getDomain()); 
     entityAnalysis.setSentimentCount(allSentimentCounts); 
     return entityAnalysis; 
    } 

답변

1
  1. , 당신은 단순히 count()를 호출 할 수 있습니다.

  2. 간단히 계산하면 키 전용 쿼리를 사용하십시오. 무료이며 훨씬 빠릅니다.

  3. 많은 수의 항목을 처리해야 할 때 검색어에 chunckAll()을 설정하는 것을 잊지 마십시오. 기본 설정보다 훨씬 빠릅니다.

이러한 예외가 계속되는 경우 쿼리에서 커서를 사용해야합니다.

+0

단지 업데이트를 제공합니다 - 당신이 제안한대로 키 전용 쿼리와'chunkAll()'을 끝내기 시작했습니다. 당신 말이 맞아서 더 빠릅니다. 그러나 여전히 확장 성을 높이기 위해 내 데이터 모델을 다시 생각해야합니다. 옵션을 가져 주셔서 감사합니다. – BlueChips23

+1

커서를 사용하여 매우 긴 쿼리를 실행할 수 있습니다. 즉, 쿼리가 500보다 작아 질 때까지 쿼리의 커서를 설정하고 쿼리를 설정하고 다시 실행하여 다음 500 개의 엔터티를 가져 오는 등 쿼리를 실행할 수 있습니다. 루프 내에서 몇 줄의 코드 일 뿐이며 필요한 경우 수백만 개의 엔티티를 처리 할 수 ​​있습니다. –