带gRPC的转管给料机中的访问变量

Question

我正试图通过从csv文件中读取数据来创建我的gRPC有效载荷（它有guestID和category列）。我在这里遵循了这个例子https://github.com/phiSgr/gatling-grpc/blob/244ab372da6773102d79c65a7e4086f409d3fe94/src/test/scala/com/github/phisgr/example/GrpcExample.scala但是当我尝试同样的方法时，我看到了一个类型不匹配错误。（它需要Seq[ContextKey]，但在这里我可以形成Seq[Expression[ContextKey]）

val scn2: ScenarioBuilder = scenario("gRPC call - 50 users repeated 100 times")
  .feed(csv("testtext.csv"))
  .exec(
    grpc("gRPC request with test message")
      .rpc(RecommenderGrpc.METHOD_GET_RECOMMENDATIONS)
      .payload(RequestContext.of(Map("test" -> "test"),
        Seq(ContextKey.defaultInstance.updateExpr(
          _.id :~ $("guestID"),
          _.`type` :~ Type.GUEST
        ), ContextKey.defaultInstance.updateExpr(
          _.id :~ $("category"),
          _.`type` :~ Type.CATEGORY
        )),
        Seq())
      )
  )

（有效负载是一个请求上下文对象，它接收元数据、键和项目。元数据是一个映射，键是ContextKey的Seq，项目是空的Seq。ContextKey包含字符串guestID或类别和类型）。

如何在这里使用进纸器中的变量？

Answer 1

跳转到底部寻找解决方案。

Expression[T]是会话的别名=

你可以考虑一个表达式[T]，抽象地“包含”一个T。

比如JavaScript中的promise如何“包含”未来价值。你不能给一个需要T的函数一个promiseT。如果想要转换或组合Promises，必须将该代码从内到外转换，并作为的参数提供。然后1

aPromise + 1 // wrong
aPromise.then(a => a + 1)

这与您的代码示例不编译的原因相同。

Gatling的用户不一定熟悉Scala或一般的函数式编程。让他们理解这种“包装”的东西会适得其反。2所以有代码可以帮助您组合表达式s。

对于HTTP和其他非类型化的东西，EL字符串被解析并转换为一个表达式。

Protobuf消息是强类型的，使用字符串插值无法轻松构造有效负载。因此，透镜上的：~操作符用于处理管道，这样您就不必手动处理表达式包装。

但是现在您有了一个函数，Request estContext.of，它可以构造有效负载。如果您需要该函数，镜头魔法无能为力。您必须自己编写表达式lambda。3

.payload { session =>
  for {
    guestId <- session("guestId").validate[String]
    category <- session("category").validate[String]
  } yield RequestContext.of(
    Map("test" -> "test"),
    Seq(
      ContextKey(id = guestID, `type` = Type.GUEST),
      ContextKey(id = category, `type` = Type.CATEGORY)
    ),
    Seq()
  )
}

>

表达式只是要么monad和Readermonad堆叠在一起，有什么问题？

如果我知道什么是RequestContext，我可能会写一个带有镜头的版本。当然了。