2

http://code.google.com/p/appengine-mapreduce/には、実行速度を制御できると記載されていますが、その方法がわかりません。マッパージョブのタスクキューを作成し、そこから速度を制御することは理にかなっていますが、使用するキューを指定する方法がわかりません。

4

3 に答える 3

2

私自身はJavaバージョンを使用していませんが、Pythonバージョンprocessing_rateにはマッパー仕様に渡すパラメーターがあります。

Javaソースをすばやく検索すると、MAPPER_INPUT_PROCESSING_RATE_KEY構成キーが見つかります。これは、正しい方向を示していることを願っています。

于 2011-05-16T20:45:07.063 に答える
2

（ポインターをくれたChrisに感謝しますが、正確なパラメーターを見つけるには、その後少し掘り下げました。）

http://code.google.com/p/appengine-mapreduce/wiki/UserGuideJavaから、これをmapreduce.xml構成要素に追加して、1秒あたりに処理されるエンティティの数を制限します。

<property>
    <name>mapreduce.mapper.inputprocessingrate</name>
    <value>4</value>
</property>
于 2012-02-01T08:43:29.070 に答える
1

Pythonを使用しているユーザーの場合、model.pyで「_DEFAULT_PROCESSING_RATE_PER_SEC」と呼ばれるこの変数を検索して、1秒あたりのデフォルトの処理速度を上げることができます。それは私のために働いた！

于 2012-02-11T08:50:50.007 に答える