如何将一个简单的迭代循环变成Gatling中的进纸器？

Question

为了在运行性能脚本之前用大量数据填充系统，我们理想的用例是使用Gatling。数据不需要不同，除了具有唯一的主ID。

object Object {

 val create = repeat(4, "n")
 {
 exec(http("Create Object") 
 .post("/our/api/objects")
 .body(ELFileBody("CreateObject_0001_request.txt"))
 .check(status.is(201)))
 }
}

val createObjects = scenario("ModularSimulation").exec(CreateObjects.create);

setUp(
 createObjects.inject(atOnceUsers(1))
).protocols(httpProtocol)

上面的示例可以通过更改repeat的值来创建任意数量的对象，但是在大范围（例如100000个对象）下，线性地这样做变得不切实际。所以我想做的是有一个共享的对象池，由100个用户创建。

当然，这就是喂食器的使用案例。而不是生成一个静态的。csv文件或使用Redis使用简单的迭代循环（例如0到100000）似乎最简单。

我知道（从文档和其他问题中）Feeder是迭代器[Map[String，T]]的一个类型别名，所以我认为这应该非常简单——但我似乎找不到这个最基本情况的简单示例。

任何帮助都将不胜感激。

Answer 1

很好的答案是Teliatko，当你需要一个基于有限馈线的无限馈线时，你也可以添加到阵列中。像这样的随机或循环：

val infiniteFeeder = (for (i <- 0 until 2) yield {
  Map("yourFiniteSessionKey" -> s"I'm finite $i")
}).toArray.random

Answer 2

我不确定你想不想实现什么，但使用feeders很容易。假设您有：

import scala.util.Random

// An infinite feeder generating random strings 
// accessible under "yourInfiniteSessionKey" from session  
val infiniteFeeder = Iterator.continually(
  Map("yourInfinteSessionKey" -> Random.alphanumeric.take(20).mkString)
)

// A finite feeder (in sense of possible values) 
// accessible under "yourFiniteSessionKey" from session
// it contains just 2 values for illustration purposes
val finiteFeeder = (for (i <- 0 until 2) yield {
  Map("yourFiniteSessionKey" -> s"I'm finite $i")
})

// A fixed feeder (again in sense of possible values)
// accessible under "yourFixedSessionKey" from session
// again it contains just 2 values for illustration purposes
val fixedFeeder = Array(
  Map("yourFixedSessionKey" -> s"I'm fixed 1"),
  Map("yourFixedSessionKey" -> s"I'm fixed 2")
)

val scn = scenario("Feeding")
  .feed(infiniteFeeder)
  .feed(finiteFeeder)
  .feed(fixedFeeder)
  .exec(http("root")
  .get("/${yourInfinteSessionKey}/${yourFiniteSessionKey}/${yourFixedSessionKey}"))

只是为了举例，我们的场景从我们所有的馈送器中获取并使用值来针对“/”组成GET请求。

在这种情况下，fix edFeeder是Array[Map[String，_]和finiteFeeder是IndexedSeq[Map[String，_]。如果有限馈源中的项目数与您的设置匹配，则可以运行该场景，例如：

setUp(
  scn.inject(atOnceUsers(2))
).protocols(httpConf)   

安装程序只有两个virual用户，因此它运行起来没有问题。当您的设置中有更多虚拟用户时，例如：

setUp(
  scn.inject(constantUsersPerSec(1) during(30.seconds)) // equals 30 virtual users
).protocols(httpConf)  

您将遇到有限/固定馈线的问题，Gatling将对此进行投诉，您的模拟将停止如下：

[error] java.lang.IllegalStateException: Feeder is now empty, stopping engine
[error]     at io.gatling.core.action.SingletonFeed.feed(SingletonFeed.scala:59)
[error]     at io.gatling.core.action.SingletonFeed$$anonfun$receive$1.applyOrElse(SingletonFeed.scala:28)
[error]     at akka.actor.Actor$class.aroundReceive(Actor.scala:467)

好消息是，您可以使用RecordSeqFeederBuilder的Gatling API方法使有限/固定馈线无限，例如：

// Now the feeder from fixed values is infinite
val fixedFeeder = Array(
  Map("yourFixedSessionKey" -> s"I'm fixed 1"),
  Map("yourFixedSessionKey" -> s"I'm fixed 2")
).circular // go back to the top of the array once the end is reached

您还可以在场景定义中直接使用此类API方法调用，并保持固定/有限馈线不变，如：

val scn = scenario("Feeding")
  .feed(infiniteFeeder)
  .feed(finiteFeeder.random) // now is finiteFeeder infinite
  .feed(fixedFeeder.circular) // fixedFeeder is infinite too
  .exec(http("root")

享受吧