在appengine上,如何将实体放入reducer中



我正在使用:

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个实体。

相关内容

  • 没有找到相关文章

最新更新