如何解决Gatling Rest API 测试 - 从 json 响应中检索一个值并将其添加到列表中,遍历列表
我是 Gatling 的新手,我正在尝试对几个 rest 调用进行性能测试。在我的场景中,我需要从第一次调用的 json 响应中提取一个值,并在循环几次后将这些值添加到列表中。再次循环几次并将值添加到列表中后,我想通过迭代列表中的值在下一次 rest 调用中重用每个值。任何人都可以请建议如何实现这一点。我尝试了以下内容,
var datasetIdList = List.empty[String]
val datasetidsFeeder = datasetIdList.map(datasetId => Map("datasetId" -> datasetId)).iterator
def createData() = {
repeat(20){
feed("").exec(http("create dataset").post("/create/data").header("content-type","application/json")
.body(StringBody("""{"name":"name"}"""))
.asJson.check(jsonPath("$.id").saveAs("userId"))))
.exec(session => { var usrid = session("userId").as[String].trim
datasetIdList:+= usrid session})
}}
def upload()= feed(datasetidsFeeder).exec(http("file upload").post("/compute-metaservice/datasets/${datasetId}/uploadFile")
.formUpload("File","./src/test/resources/data/File.csv")
.header("content-type","multipart/form-data")
.check(status is 200))
val scn = scenario("create data and upload").exec(createData()).exec(upload())
setUp(scn.inject(atOnceUsers(1))).protocols(httpConf)
}
我在尝试运行上面的脚本时看到 ListFeeder 为空的异常。有人可以帮忙吗
更新代码:
class ParallelcallsSimulation extends Simulation{
var idNumbers = (1 to 50).iterator
val customFeeder = Iterator.continually(Map(
"name" -> ("test_gatling_"+ idNumbers.next())
))
val httpConf = http.baseUrl("http://localhost:8080")
.header("Authorization","Bearer 6a4aee03-9172-4e31-a784-39dea65e9063")
def createDatasetsAndUpload() = {
repeat(3) {
//create dataset
feed(customFeeder).exec(http("create data").post("/create/data").header("content-type","application/json")
.body(StringBody("""{ "name": "${name}","description": "create data and upload file"}"""))
.asJson.check(jsonPath("$.id").saveAs("userId")))
.exec(session => {
val name = session("name").asOption[String]
println(name.getOrElse("COULD NOT FIND NAME"))
val userId = session("userId").as[String].trim
println("%%%%% User ID ====>"+userId)
val datasetIdList = session("datasetIdList").asOption[List[_]].getOrElse(Nil)
session.set("datasetIdList",userId :: datasetIdList)
})
}
}
// File Upload
def fileUpload() = foreach("${datasetIdList}","datasetId"){
exec(http("file upload").post("/uploadFile")
.formUpload("File","./src/test/resources/data/File.csv")
.header("content-type","multipart/form-data")
.check(status is 200))
}
def getDataSetId() = foreach("${datasetIdList}","datasetId"){
exec(http("get datasetId")
.get("/get/data/${datasetId}")
.header("content-type","application/json")
.asJson.check(jsonPath("$.dlp.dlp_job_status").optional
.saveAs("dlpJobStatus")).check(status is 200)
).exec(session => {
val datastId = session("datasetId").asOption[String]
println("request for datasetId >>>>>>>>"+datastId.getOrElse("datasetId not found"))
val jobStatus = session("dlpJobStatus").asOption[String]
println("JOB STATUS:::>>>>>>>>>>"+jobStatus.getOrElse("Dlp Job Status not Found"))
println("Time: >>>>>>"+System.currentTimeMillis())
session
}).pause(10)
}
val scn1 = scenario("create multiple datasets and upload").exec(createDatasetsAndUpload()).exec(fileUpload())
val scn2 = scenario("get datasetId").pause(100).exec(getDataSetId())
setUp(scn1.inject(atOnceUsers(1)),scn2.inject(atOnceUsers(1))).protocols(httpConf)
}
当我尝试执行上述脚本时看到以下错误 [错误] i.g.c.s.LoopBlock$ - 条件评估崩溃,消息“未定义名为“datasetIdList”的属性”,退出循环
解决方法
var datasetIdList = List.empty[String]
定义了一个指向不可变列表的可变变量。
val datasetidsFeeder = datasetIdList.map(datasetId => Map("datasetId" -> datasetId)).iterator
使用不可变列表。对 datasetIdList
的进一步更改与 datasetidsFeeder
无关。
用你的虚拟用户改变全局变量通常不是一个好主意。 您可以将该值保存到用户的 session 中。
在exec块中,你可以这样写:
val userId = session("userId").as[String].trim
val datasetIdList = session("datasetIdList").asOption[List[_]].getOrElse(Nil)
session.set("datasetIdList",userId :: datasetIdList)
然后您可以使用 foreach 来迭代它们,而根本不使用 Feeder。
foreach("${datasetIdList}","datasetId") {
exec(http("file upload")
...
}
你应该在你的问题上做更多的工作。
- 您的代码没有语法突出显示,并且格式很差。
- 您说“我看到 ListFeeder 为空的异常”,但在任何地方都看不到“ListFeeder”这个词。
- 您应该发布错误消息,以便更容易地查看问题所在。
在链接的文档中,有一个警告。引用如下:
Session
实例是不可变的!
为什么会这样?因为 Session 是多线程并发处理的消息,所以不可变性是最好的状态处理方式,不依赖于同步和阻塞。
一个非常常见的陷阱是忘记 set
和 setAll
实际上返回新实例。
这就是更新问题中的代码没有更新列表的原因。
session => {
...
session.set("datasetIdList",userId :: datasetIdList)
println("%%%% List =====>>>" + datasetIdList.toString())
session
}
更新的会话被简单地丢弃。并在匿名函数中返回原始会话。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。