App Engine MapReduce映射器错误模型类型通过

Question

嘿，我在这里遵循文档:Google MapReduce

class StationsBlobstoreHandler(webapp.RequestHandler):
''''''
def get(self):
    mr_job = mapreduce_pipeline.MapPipeline(
        'calculate_sha1_stations_logos',
        'radioflag.admin.mapreduce.blobfixstations.station_avatar_mapper',
        'mapreduce.input_readers.DatastoreEntityInputReader',
        {'entity_kind': 'myproj.engine.db.model.StationAvatar'})
    mr_job.start()
def station_avatar_mapper(station_avatar):
    logging.info(type(station_avatar))

但是我的映射器被调用而不是myproject .engine.db.model. stationavatar .

我怎样才能在我的映射器中得到正确的模型。

PS:仅将StationAvatar传递给entity_kind不能正常工作

Answer 1

我发现我应该使用DatastoreInputReader而不是DatastoreEntityInputReader。

对不起:)