如何使用Gatling运行Guidewire批处理作业并编写Scala脚本

前置准备 #

• 搞定Gatling和Scala的环境配置，确保能正常运行Gatling脚本
• 拿到Guidewire批处理作业的触发接口地址（一般是REST端点）
• 准备好Guidewire的认证凭据，比如Bearer Token或者用户名密码

核心Scala脚本实现 #

直接上可复用的脚本模板，按需替换占位内容：

import io.gatling.core.Predef._
import io.gatling.http.Predef._
import scala.concurrent.duration._

class GuidewireBatchJobSimulation extends Simulation {

  // 配置HTTP协议基础参数
  val httpProtocol = http
    .baseUrl("https://your-guidewire-instance.com") // 替换成你的Guidewire实例地址
    .acceptHeader("application/json")
    .authorizationHeader("Bearer YOUR_VALID_AUTH_TOKEN") // 替换为有效认证Token，用Basic Auth就换basicAuth("user", "pass")

  // 定义触发批处理作业的请求
  val triggerBatchJob = exec(http("Trigger Guidewire Batch Job")
    .post("/gw/rest/v1/batch/jobs/YOUR_JOB_ID/trigger") // 替换为目标作业的触发接口
    .body(StringBody("""{"executionDate": "2024-05-20", "businessParam": "sample-value"}""")) // 替换成作业需要的参数
    .check(status.is(202)) // 验证请求被成功接受
    .check(jsonPath("$.jobId").saveAs("batchJobId"))) // 保存返回的作业ID，用于后续查状态

  // 可选：循环查询作业状态直到完成
  val checkJobCompletion = repeat(15, "loopCount") { // 最多查15次
    exec(http("Check Batch Job Status")
      .get("/gw/rest/v1/batch/jobs/${batchJobId}/status")
      .check(status.is(200))
      .check(jsonPath("$.status").is("COMPLETED"))) // 确认作业状态为完成
      .pause(20 seconds) // 每次查询间隔20秒，可按需调整
  }

  // 定义完整场景
  val batchJobScenario = scenario("Run Guidewire Batch Job")
    .exec(triggerBatchJob)
    .exec(checkJobCompletion) // 不需要等完成就删掉这行

  // 设置负载规则（批处理一般单实例触发，按需调整）
  setUp(
    batchJobScenario.inject(
      atOnceUsers(1) // 立即启动1个用户触发作业
      // 要测多批并行就改成rampUsers(3) over (5 seconds)
    )
  ).protocols(httpProtocol)
}

关键细节说明 #

• 认证适配：如果Guidewire用Basic认证，把authorizationHeader换成basicAuth("your-username", "your-password")就行
• 参数调整：请求体里的参数完全根据你的批处理作业要求来改，比如作业类型、执行范围这些
• 状态查询：如果不需要等待作业结束，直接删掉checkJobCompletion部分；要验证作业输出的话，可以扩展查询接口获取结果数据
• 负载控制：批处理作业通常不需要高并发，单用户触发足够；要是测试多批作业同时运行的场景，再调整并发数

运行与验证 #

• 把脚本存成GuidewireBatchJobSimulation.scala，放到Gatling的user-files/simulations目录下
• 启动Gatling，选择这个脚本运行
• 跑完看Gatling生成的报告，确认请求状态、响应时间这些指标是否符合预期

内容的提问来源于stack exchange，提问作者Asis Kumar Swain