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;
}
ちょうどアップデートを提供する - あなたが提案したように、キーのみのクエリと 'chunkAll()'をやり終えた。あなたは正しいです、そして、それはより速いです。しかし、私はまだデータモデルを再スケーラブルにするために再考する必要があります。オプションありがとう。 – BlueChips23
カーソルを使用して、非常に長いクエリを実行することができます。すなわち、クエリが500未満になるまで、エンティティ数が500個のクエリを実行し、クエリカーソルを取得し、クエリに設定し、再度実行して次の500個のエンティティを取得しますループのコードはほんの数行で、必要に応じて何百万ものエンティティを処理できます。 –