使用 Google AppEngine MapReduce 处理所有记录后,如何从计数器获取值?
或者我在这里错过了计数器的用例?
示例代码来自http://code.google.com/p/appengine-mapreduce/wiki/UserGuidePython http://code.google.com/p/appengine-mapreduce/wiki/UserGuidePython
我如何检索计数器的值counter1MapReduce什么时候完成?
app.yaml
handlers:
- url: /mapreduce(/.*)?
script: mapreduce/main.py
login: admin
映射减少/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 会话的管理页面上。也必须有一种方法可以从映射器内部访问值,但我对 API 的 Python 版本还不够熟悉,无法告诉您如何操作。我知道这在Java方面是可行的。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)