在使用 Google AppEngine MapReduce 处理完所有记录后,如何从计数器中获取值?
还是我在这里遗漏了计数器的用例?
示例代码来自 http://code.google.com/p/appengine-mapreduce/wiki/UserGuidePython
当 mapreduce 完成时,我如何检索计数器 counter1 的值?
app.yaml
handlers:
- url: /mapreduce(/.*)?
script: mapreduce/main.py
login: admin
mapreduce/main.py
from mapreduce import operation as op
def process(entity):
yield op.counters.Increment("counter1")
mapreduce.yaml
mapreduce:
- name: <Some descriptive name for UI>
mapper:
input_reader: mapreduce.input_readers.DatastoreInputReader
handler: main.process
params:
- name: entity_kind
default: <your entity name, e.g. main.MyEntity>
好的。由于您是从文档中发布代码,因此我假设您还没有尝试运行映射器。计数器的结果应该显示在 mapreduce session 的管理页面上。也必须有一种方法可以从映射器中访问值,但我对 API 的 Python 版本不够熟悉,无法告诉您如何操作。我知道它在 Java 方面是可行的。
我是一名优秀的程序员,十分优秀!