0

Google App Engine v.1.9.48を使用しています。私のデータストアのクエリ中に、私はランダムに "CancellationException:タスクがキャンセルされました"というエラーが出ています。そして、私は本当にこのエラーの原因を正確にはわかりません。 other Stackoverflow postsから、これはタイムアウトと関係があるとはっきりと理解していますが、これを引き起こしていることは完全にはわかりません。私はTaskQueuesを使用していません - それが役立つ場合。ここでそのエラーを投げているGoogle Datastoreクエリの実行中に「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()の1で)でスローされている行のコメントにコメントを追加しました:

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()を呼び出すことができ、.list().size()を呼び出す必要はありません。

  2. 単純にカウントすれば、キーのみのクエリを使用します。これは無料で、はるかに高速です。

  3. 大量のエンティティを処理すると予想される場合は、chunckAll()をクエリに設定することを忘れないでください。デフォルト設定よりもはるかに高速です。

これらの例外が発生する場合は、クエリでカーソルを使用する必要があります。

+0

ちょうどアップデートを提供する - あなたが提案したように、キーのみのクエリと 'chunkAll()'をやり終えた。あなたは正しいです、そして、それはより速いです。しかし、私はまだデータモデルを再スケーラブルにするために再考する必要があります。オプションありがとう。 – BlueChips23

+1

カーソルを使用して、非常に長いクエリを実行することができます。すなわち、クエリが500未満になるまで、エンティティ数が500個のクエリを実行し、クエリカーソルを取得し、クエリに設定し、再度実行して次の500個のエンティティを取得しますループのコードはほんの数行で、必要に応じて何百万ものエンティティを処理できます。 –

関連する問題