如何在AppEngine上節省appengine-mapreduce？

http://code.google.com/p/appengine-mapreduce/提到它可以控制執行速度，但是我想不出怎麼樣。爲映射器作業創建一個任務隊列並控制其速度是有意義的，但我不明白如何指定要使用哪個隊列。如何在AppEngine上節省appengine-mapreduce？

2011-05-16 Riley Lark

（感謝Chris爲指針，但它花了一點後挖，找到確切的參數。）

從http://code.google.com/p/appengine-mapreduce/wiki/UserGuideJava添加到您的mapreduce.xml配置元素，以限制加工的實體數量每秒：

<property> 
    <name>mapreduce.mapper.inputprocessingrate</name> 
    <value>4</value> 
</property>

2012-02-01 08:43:29 Casey

啊，謝謝你添加這個後續。如果您正在以編程方式設置您的映射器，您也可以直接在Java中使用MAPPER_INPUT_PROCESSING_RATE_KEY。 – 2012-02-01 15:32:59

我自己不使用Java版本，但Python版本有一個processing_rate參數，您將其傳遞給映射器規範。

在Java源代碼中快速搜索會顯示一個MAPPER_INPUT_PROCESSING_RATE_KEY配置密鑰，希望您可以指出正確的方向。

2011-05-16 20:45:07

對於使用Python用戶，你可能要搜索此變量稱爲「_DEFAULT_PROCESSING_RATE_PER_SEC」在model.py增加每秒的默認處理率。這對我有效！

2012-02-11 08:50:50 autumngard

回答