0

我正在使用 Mapreduce 处理实体类型中的所有条目，并为此目的使用 datastoreinputkeyreader。但它没有为该实体中的所有条目带来密钥。如果实体有 2000 个条目，它只为大约 150 个条目带来密钥。可能是什么问题？这是一个限制吗？

这是管道类

class MatchingPipeline(base_handler.PipelineBase):
def run(self,parent_key_):
    output = yield mapreduce_pipeline.MapreducePipeline(
        parent_key_,
        "controllers.matcher.match",
        "controllers.matcher.reducer",
        "mapreduce.input_readers.DatastoreKeyInputReader",
        "mapreduce.output_writers.BlobstoreOutputWriter",
        mapper_params={
            "entity_kind": 'DataIncoming',
        },
        reducer_params={
            "mime_type": "text/plain",
        },
        shards=16)

class DataTransfer(webapp2.RequestHandler):
def get(self):
    pipeline = MatchingPipeline('Matcher')
    pipeline.start()
4

0 回答 0