App Engine MapReduce mapper неверный вид модели пройден - PullRequest
Новая
       5

App Engine MapReduce mapper неверный вид модели пройден

0 голосов
/ 23 ноября 2011

Эй, я следил за документацией здесь: 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))

Но мой маппер вызывается вместо myproj.engine.db.model.StationAvatar.

Как я могу получить правильные модели в моем картографе.

PS: передача только StationAvatar в entity_kind также не работает

1 Ответ

2 голосов
/ 23 ноября 2011

ОК. Я обнаружил, что должен использовать DatastoreInputReader вместо DatastoreEntityInputReader.

Извините:)

...