2017-02-25 23 views
1

我有一個gatling場景,我通過RESTful API從數據庫中檢索1000個文檔。gatling組在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循環確保每個請求被髮送一個在另一個之後。

問題

我真正想要的是通過1000個結果中的10組工作,同時並行發送10更新請求。

我該如何做到這一點?

回答

0

嘗試將提取部分移至hook之前。

現在,你有數據,你可以啓動10個線程

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

不幸的是我需要得到的數據是場景的一部分的請求。 – ndtreviv