2017-02-25 8 views
1

私はRESTful APIを介してデータベースから1000個のドキュメントを取得するガットリングのシナリオを持っています。グループアクションをforeachで並列チャンクに変換

私は文書を修正し、それぞれの更新要求を送信します。

これは、私は現在、それをやっている方法です:

... 
val scrollQueries = scenario("Enrichment Topologies").exec(ScrollQueryInitiator.query, repeat(numberOfPagesToScrollThrough, "scrollQueryCounter"){ 
    exec(ScrollQuery.query, pause(10 seconds).foreach("${hitsJson}", "hit"){ exec(HitProcessor.query) }) 
}) 
... 

は、ここで関心の主な機能は次のとおりです。

  1. ScrollQuery.queryが1000件の結果をフェッチし、セッション中にhitsJsonにそれらを保存します。
  2. その後、長期間の処理をシミュレートするために10秒間停止します。
  3. 1000の結果を反復処理し、各項目HitProcessorためのものであるが、実際に

更新要求を送信する実行され、foreachループは、各要求が次々に送信されることを保証します。私が本当に欲しい

質問

は、一度に10を並列に更新要求を送信し、10のグループの1000の結果を介して動作することです。

どうすればこの問題を解決できますか?

答えて

0

hookの前にフェッチ部分を移動してみてください。

今、あなたがデータを持っていることを、あなたは、残念ながら、私はデータは、シナリオの一部であることを得る要求を必要とする10件のスレッド

setUp( scn.inject(atOnceUsers(10))) 
+0

を開始することができます。 – ndtreviv

関連する問題