我正在尝试有效地调用 tasklet 和 subtasklet:
@ndb.tasklet
def getBeds(bed_key):
bed = yield bed_key.get_asyn()
bed_info = {}
......
raise ndb.Return(bed_info)
@ndb.tasklet
def getRoom(room_key):
room = yield room_key.get_async()
room_info = {}
..........
beds_in_room = map(getBeds,room.beds)
room_info["beds"] = beds_in_room
raise ndb.Return(room_info)
@ndb.tasklet
def getBuilding(build_key):
build = yield build_key.get_async()
build_info = {}
...........
rooms_in_build = map(getRoom,build.rooms)
build_info["rooms"] = rooms_in_build
@ndb.toplevel
def getHotel(hotel_obj)
hotel_inf = {}
.........
buildings_in_hotel = map(getBuilding,hotel_obj.buildings)
hotel_inf["buildings"] = buildings_in_hotel
return hotel_inf
出于某种原因,我虽然 @ndb.toplevel 会暂停 getHotel 直到一切完成。不幸的是,buildings_in_hotel 正在返回一个期货列表......
我如何让它完成?