python - 使用查询迭代器在 python 中查询应用程序引擎的游标

Question

我想使用分页而不是通过调用，

greets, next_curs, more = Greeting.query().fetch_page(10, start_cursor=curs)

但是通过使用查询迭代器。因为这样我就可以使用小线程将所有连续的“获取”组合在一起，如 https://developers.google.com/appengine/docs/python/ndb/async#tasklets 中所述。

现在在我的代码中，事情看起来像，

class Book(ndb.Model):
    author = ndb.KeyProperty('a', kind=User, required=True)

author_key = ndb.Key(urlsafe=user_id)
books_query=Book.query(Book.author == author_key)
@ndb.tasklet
def callback(book):
     author = yield book.author.get_async()
     raise ndb.Return(book, author)

q_option = {'limit' : 2, 'produce_cursors' : True }
outputs = books_query.map(callback, **q_option)

不确定哪里出了问题，但如果我尝试这样做，

books_query.iter().cursor_before() 

或

books_query.iter().cursor_after()

它失败并显示以下跟踪，

raise datastore_errors.BadArgumentError('There is no cursor currently')
BadArgumentError: There is no cursor currently

任何使用查询迭代器和带游标的微线程的详细示例都将非常有助于我理解这一点。

Answer 1

books_query.iter().cursor_after() 依赖于 .iter(**q_options)，后者使用自己的参数创建一个 QueryIterator。

问题是无法访问 .map() 使用的内部迭代器。

请参阅 Guido 对有关该主题的相关问题的回答:https://stackoverflow.com/a/14150081/2380615