使用存根值从JSON编写Gatling定制feeder

Question

如何根据JSON文件编写自定义Gatling进纸器，该文件具有某些已存根且需要在发送前替换的值？例如

{"payloads":[
  {"groupId":"<GUID>", "epoch":<TIME>, "report":"somethingInteresting1"},
  {"groupId":"<GUID>", "epoch":<TIME>, "report":"somethingInteresting2"},
  {"groupId":"<GUID>", "epoch":<TIME>, "report":"somethingInteresting3"}
]}

jsonFile("/opt/gatling/user-files/simulation/cannedPayloads.json")

我想这行不通，因为它在文件中不是有效的JSON。我试过：

val jsonFileContents = Source.fromFile("/opt/gatling/user-files/simulation/cannedPayloads.json").getLines.mkString
.replaceAll("<GUID>", java.util.UUID.randomUUID().toString())
.replaceAll("<TIME>", Instant.now().toEpochMilli().toString())

val feeder = JsonPath.query("$.payloads[*]", jsonFileContents).right.get.toArray.circular

val scn1 = scenario("CannedTestSimulation").exec(feed(feeder).exec(
  http("to ingestion").post(url).body(StringBody("$")).asJSON
)

Answer 1

我通过读取文件、执行替换、将其写入临时文件，并使用Gatling的内置jsonFile来绕过它。JSON的基础变成了

[
  {"groupId":"<GUID>", "epoch":<TIME>, "report":"somethingInteresting1"},
  {"groupId":"<GUID>", "epoch":<TIME>, "report":"somethingInteresting2"},
  {"groupId":"<GUID>", "epoch":<TIME>, "report":"somethingInteresting3"}
]

情况变得更糟了

val scn1 = scenario("CannedTestSimulation").feed(jsonFile(CannedRequests.createTempJsonFile())).exec(
  http("send data").post(url).body(StringBody("$")).asJSON
)

然后罐头变成了

object CannedRequests {
val jsonFile = "/opt/gatling/user-files/simulations/stubbed_data.json"


def jsonFileContents(testSessionId: String): String = 
Source.fromFile(jsonFile).getLines.mkString
.replaceAll("<GUID>", "gatling_"+testSessionId)
.replaceAll("<TIME>", Instant.now().toEpochMilli().toString())

def createTempFile(contents: String, testSessionId: String): File = {
 val tempFile = File.createTempFile(testSessionId, ".json")
 val bw = new BufferedWriter(new FileWriter(tempFile))
 bw.write(contents)
 bw.close

 tempFile
}

def createTempJsonFile():String = {
val tempSessionId = java.util.UUID.randomUUID().toString()
val tempContents = jsonFileContents(tempSessionId)
val tempFile = createTempFile(tempContents, tempSessionId)

tempFile.getAbsolutePath
}
}