在appengine上，我如何將一個實體放入reducer中？

Question

我使用：

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

和演示程序開始。

我應該如何將實體寫入數據存儲？產生一個放置操作？輸出寫入器類型應該是什麼？

Answer 1

是的，我用的產量像這樣放置操作：

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個實體。