我正在使用:
http://code.google.com/p/appengine-mapreduce/
并从演示应用程序开始。
我应该如何将实体写入数据存储?卖出看跌期权?输出编写器类型应该是什么?
是的,我在看跌操作中使用了收益率,如下所示:
def makethumbnails(entity):
if entity.small:
try:
entity.thumb = images.resize(entity.small, 80, 100)
except Exception, e:
pass
yield op.db.Put(entity)
在我的mapreduce.yaml中,相应的元素是
- name: makethumbnails
mapper:
input_reader: mapreduce.input_readers.DatastoreInputReader
handler: main.makethumbnails
params:
- name: entity_kind
default: main.Image
这是一个对我有效的组合,或者如果你只想更新大量实体的变量:
def seturl(entity):
if entity.url:
if entity.url.find('mydomainname') > 1:
try:
entity.url = 'www.mydomainname.com'
yield op.db.Put(entity)
except Exception, e:
logging.debug('There occurred exception:%s' % str(e))
使用上述操作,我可以在一份工作中处理大约15000个实体。