def iterate_over_query_results_in_tasklet(Model, is_the_entity_i_want):
qry = Model.query()
qit = qry.iter()
while (yield qit.has_next_async()):
entity = qit.next()
# Do something with entity
if is_the_entity_i_want(entity):
raise ndb.Return(entity)
评论列表
文章目录