Трудность заставить ndb.tasklets работать в Google App Engine

Question

У меня возникли трудности с пониманием того, что происходит с некоторыми тасклетами, которые я написал для использования с асинхронными API-интерфейсами хранилища данных Google App Engine. Обзор таков: мне нужно собрать историю покупок для пользователя, и объект "UserPurchase" ссылается на "Продукт" или "Пользовательский" предмет, который был приобретен, и "Заведение", в котором он был приобретен, оба с помощью KeyProperty. свойства в UserPurchase ndb.Model. Я хочу максимально распараллелить различные поиски NDB, поэтому я достаточно близко придерживался документации по NDB (по адресу https://cloud.google.com/appengine/docs/standard/python/ndb/async) и создал 3 тасклета:

@ndb.tasklet
def get_establishment(purch):
    resto = yield purch.p_establishment.get_async()
    ret = {
        "rkey": resto.key.urlsafe(),
        "rname": resto.resto_name
    }
    raise ndb.Return(ret)

@ndb.tasklet
def get_item(purch):
    item = yield purch.p_item.get_async()
    if (purch.p_item.kind() == "Product"):
        ret = {
            "ikey": item.key.urlsafe(),
            "iname": item.name
        }
    else:
        ret = {
            "ikey": item.key.urlsafe(),
            "iname": item.cust_name
        }
    raise ndb.Return(ret)

@ndb.tasklet
def load_history(purch):
    at, item = yield get_establishment(purch), get_item(purch)
    ret = {
        "date": purch.p_datetime,
        "at_key": at.rkey,
        "at": at.rname,
        "item_key": item.ikey,
        "item": item.iname,
        "qty": purch.p_quantity,
        "type": purch.p_type
    }
    raise ndb.Return(ret)

Затем я звоню так:

pq = UserPurchase.query().order(-UserPurchase.p_datetime)
phistory = pq.map(load_history, limit = 20)

чтобы получить последние 20 покупок для отображения. Однако, когда я запускаю его, я получаю странное исключение, из которого я не знаю, что делать... и я недостаточно знаком с тасклетами и тем, как они работают, чтобы с уверенностью сказать, что я знаю, что происходит. Я был бы очень признателен, если бы кто-нибудь дал мне несколько советов о том, что искать...! Вот исключение, которое я получаю, когда запускаю приведенный выше код:

      ...
       File "/Programming/VirtualCellar/server/virtsom.py", line 2348, in get
        phistory = pq.map(load_history, limit = 20)
      File "/Applications/GoogleAppEngineLauncher.app/Contents/Resources/GoogleAppEngine-default.bundle/Contents/Resources/google_appengine/google/appengine/ext/ndb/utils.py", line 160, in positional_wrapper
        return wrapped(*args, **kwds)
      File "/Applications/GoogleAppEngineLauncher.app/Contents/Resources/GoogleAppEngine-default.bundle/Contents/Resources/google_appengine/google/appengine/ext/ndb/query.py", line 1190, in map
        **q_options).get_result()
      File "/Applications/GoogleAppEngineLauncher.app/Contents/Resources/GoogleAppEngine-default.bundle/Contents/Resources/google_appengine/google/appengine/ext/ndb/tasklets.py", line 383, in get_result
        self.check_success()
      File "/Applications/GoogleAppEngineLauncher.app/Contents/Resources/GoogleAppEngine-default.bundle/Contents/Resources/google_appengine/google/appengine/ext/ndb/tasklets.py", line 624, in _finish
        result = [r.get_result() for r in self._results]
      File "/Applications/GoogleAppEngineLauncher.app/Contents/Resources/GoogleAppEngine-default.bundle/Contents/Resources/google_appengine/google/appengine/ext/ndb/tasklets.py", line 383, in get_result
        self.check_success()
      File "/Applications/GoogleAppEngineLauncher.app/Contents/Resources/GoogleAppEngine-default.bundle/Contents/Resources/google_appengine/google/appengine/ext/ndb/tasklets.py", line 430, in _help_tasklet_along
        value = gen.send(val)
      File "/Programming/VirtualCellar/server/virtsom.py", line 2274, in load_history
        "at_key": at.rkey,
    AttributeError: 'dict' object has no attribute 'rkey'

Судя по этой ошибке, похоже, что тасклетам не нравится возвращать словари...

Answer 1

Вы неверно истолковываете сообщение об ошибке: возвращен дикт, но вы пытаетесь получить доступ к атрибуту этого диктанта, который не существует.

Похоже, вы хотите получить доступ к значению внутри этого dict, а не к атрибуту dict, если так, то измените внутри load_history:

        "at_key": at.rkey,

чтобы:

        "at_key": at.get('rkey'),

или же:

        "at_key": at['rkey'],

Вы также хотите вернуться к своим другим подобным попыткам доступа к другим значениям dict в at а также item dicts.