Gatling更新文件，用于在调用前在feed（）中馈送模拟

Question

我需要更新包含Gatling模拟中使用的一些id的. csv文件，因为我需要事先创建数据。我试图在前（）调用中更新该文件，但它不起作用。懒惰评估也不起作用。

  before {
    Helper.CreateDocuments()
  }

  lazy val documentIds = csv("data/documentIds.csv").circular

  val scn: ScenarioBuilder = scenario("PutFile")
    .feed(documentIds)
    .exec(http("Dynamic id")
      .put("files/${documentId}"))...

我怎样才能解决这个问题，用刷新的ID为模拟提供数据？

Answer 1

您应该能够在前步骤中修改csv文件。例如：

  before {
    val pw = new PrintWriter(new File("data.csv"))
    for (i <- 0 to 10) {
      pw.write(i + "\n")
    }
    pw.close
  }

记得导入库导入java.io._

然后在模拟中使用它调用文件：

val orderId = csv("data.csv").queue

但是，这可能是多余的，因为您可以使用saveAs步骤创建值，如Gatling会话API文档中所述。例如，您可以执行以下操作：

val someHttpCall = http("Create data for the feeder").get("/my/resource").saveAs("data")

然后在进料器中使用：

val scn = feed(data).exec(somethingElse)

如果这还不够，请记住，您还可以在simulation类中的任意点创建自己的馈线。

Answer 2

我遇到过类似的问题，然后我决定不使用CSV，而是使用隐式馈线，并创建一个构建馈线的方法。我无法通过使用前钩子来解决这个问题，因此为我的馈线创建了一个构建器方法。它将如何工作的示例。

import io.gatling.core.Predef._
import io.gatling.core.structure.ChainBuilder
import io.gatling.http.Predef._
import org.apache.http.client.methods.{HttpGet, HttpPost}
import org.apache.http.entity.StringEntity
import org.apache.http.impl.client.HttpClientBuilder
import org.apache.http.util.EntityUtils
import spray.json.DefaultJsonProtocol._
import spray.json._

object TestFacade {    
var test_feeder = getFeeder()
    
      val test_scenario: ChainBuilder = feed(test_feeder).group("TEST_GROUP") {
        exec(
          http("POST /test")
            .post("/test")
            .header("Content-Type", Configuration.APPLICATION_JSON)
            .body(ElFileBody("test.json"))
            .asJSON
            .check(status.find.in(200))
        )
      }
    
      def getFeeder() = {
        val result = getRestContent("http://www.randomnumberapi.com/api/v1.0/random?min=100&max=1000&count=5")
    
        val ids = result.parseJson.convertTo[Array[Int]]
        var coolVars = Array.empty[Map[String, String]]
    
        for (id <- ids) {
          println(id)
          coolVars = coolVars :+ Map("coolVar" -> id.toString)
        }
    
        coolVars.random
      }
      
      def getRestContent(url: String): String = {
        val httpClient = HttpClientBuilder.create().build()
        val httpResponse = httpClient.execute(new HttpGet(url))
        val entity = httpResponse.getEntity
        var content = ""
        if (entity != null) {
          content = EntityUtils.toString(entity, "UTF-8")
        }
        httpClient.getConnectionManager.shutdown()
    
        content
      }
}