Блог

Я хочу добавить условие в http-запрос. как и в этом сценарии, используя API,

1. У меня есть одно действие, из которого я нахожу «Идентификатор действия»

2. Используя этот «Идентификатор действия», я проверяю статус этого действия, которое является «Запущенным / ожидающим / завершенным / etc», и сохраняю его в переменной

Я сделал это в эти два шага, теперь я хочу сделать

3. Я должен проверять состояние при условии каждые 20 минут, если статус «Выполняется», повторно проверять статус каждые 20 минут, если статус = «завершено», а затем автоматически выходить или выходить через 2 часа (даже если статус находится в рабочем состоянии)

РЕДАКТИРОВАТЬ: хотите поставить условие следующим образом,

 Check status = true
{   
    pause for 15minutes
    request once again after 15minutes
    if(status = false)
    {
        exit
    }
    else
    {
        request once again and check status, if true wait for 15minutes
        If total waiting time is more than 2 hours then exit
    }
}
else
{
    exit
}
  

ниже приведен фрагмент кода, который я сделал,

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

class LaunchResources extends Simulation {

    val scenarioRepeatCount = Integer.getInteger("scenarioRepeatCount", 1).toInt
    val userCount = Integer.getInteger("userCount", 1).toInt
    val UUID  = System.getProperty("UUID", "24d0e03")
    val username = System.getProperty("username", "p1")
    val password = System.getProperty("password", "P12")
    val testServerUrl = System.getProperty("testServerUrl", "https://someurl.net")

    val httpProtocol = http
        .baseURL(testServerUrl)
        .basicAuth(username, password)
        .connection("""keep-alive""")
        .contentTypeHeader("""application/vnd json""")

    val headers_0 = Map(
        """Cache-Control""" -> """no-cache""",
        """Origin""" -> """chrome-extension://fdmmgasdw1dojojpjoooidkmcomcm""")

    val scn = scenario("LaunchAction")
        .repeat (scenarioRepeatCount) {
            exec(http("LaunchAResources")
                .post( """/api/actions""")
                .headers(headers_0)
                .body(StringBody(s"""{"UUID": "$UUID", "stringVariables" : {"externalFilePath" : "/Test.mp4"}}"""))
                .check(jsonPath("$.id").saveAs("WorkflowID")))


        .exec(http("SaveWorkflowStatus")
                .get("""/api/actions/{$wflowid}""")
                .headers(headers_0)
                .check(jsonPath("$.status").saveAs("WorkflowStatus")))

        .asLongAs(session => session.attributes("WorkflowStatus") != false) {
    pause(900)
    .exec(http("SaveWorkflowStatus")
            .get("""/api/actions/${WorkflowID}""")
            .headers(headers_0)
            .check(jsonPath("$.running").saveAs("WorkflowStatus")))

    }

        }


    setUp(scn.inject(atOnceUsers(userCount))).protocols(httpProtocol)
}
  

Пожалуйста, помогите. Спасибо

Попробуйте это asLongAs(session => session.attributes(response) != "MY STATUS") {
exec( http().get(). .check(xpath("//status").saveAs(response) ) }

таким образом, в основном это будет продолжаться до тех пор, пока значение ответа не будет равно МОЕМУ СТАТУСУ.

Вы также можете добавить другие условия короткого замыкания в asLongAs.