python - MapReduce 难以理解

Question

我看到了下面的链接，它是关于 python 的 MapReduce 入门

http://code.google.com/p/appengine-mapreduce/wiki/GettingStartedInPython

但我仍然无法理解它是如何工作的。我正在执行下面的代码，但无法理解究竟发生了什么？

ma​​preduce.yaml

mapreduce: 
- name: Testmapper 
   mapper: 
       input_reader: mapreduce.input_readers.DatastoreInputReader 
       handler: main.process 
   params: 
       - name: entity_kind 
         default: main.userDetail

ma​​preduce/main.py

some code

class userDetail(db.Model): 
name = db.StringProperty()

some code

def process(u): 
          u.name="mahesh" 
          yield op.db.Put(u)

我正在执行此操作，它在状态页面中显示 status = success。

但无法理解发生了什么

我想用mapreduce做的主要事情是搜索或统计实体中的记录

所以有人可以帮助我吗？

提前致谢

Answer 1

您正在将“mahesh”值设置为所有 userDetail 实体的 StringProperty name。

如果您想计算实体数量，请使用:

from mapreduce import operation as op
 def process(entity):
    yield op.counters.Increment("counter1")