20_async.yml

---
requires:
  serverless: false
  stack: true
---
setup:
  - do:
      indices.create:
        index: esql-async-test
        body:
          mappings:
            properties: { 'client.ip': { 'type': 'ip' }, 'message': { 'type': 'keyword' } }
  - do:
      bulk:
        refresh: true
        index: esql-async-test
        body:
          - "index": {}
          - { "@timestamp": "2023-10-23T12:15:03.360Z", "client.ip": "172.21.2.162", "message": "Connected to 10.1.0.3", "event.duration": 3450233 }
          - "index": {}
          - { "@timestamp": "2023-10-23T12:27:28.948Z", "client.ip": "172.21.2.113", "message": "Connected to 10.1.0.2", "event.duration": 2764889 }
          - "index": {}
          - { "@timestamp": "2023-10-23T13:33:34.937Z", "client.ip": "172.21.0.5", "message": "Disconnected", "event.duration": 1232382 }
          - "index": {}
          - { "@timestamp": "2023-10-23T13:51:54.732Z", "client.ip": "172.21.3.15", "message": "Connection error", "event.duration": 725448 }
          - "index": {}
          - { "@timestamp": "2023-10-23T13:52:55.015Z", "client.ip": "172.21.3.15", "message": "Connection error", "event.duration": 8268153 }
          - "index": {}
          - { "@timestamp": "2023-10-23T13:53:55.832Z", "client.ip": "172.21.3.15", "message": "Connection error", "event.duration": 5033755 }
          - "index": {}
          - { "@timestamp": "2023-10-23T13:55:01.543Z", "client.ip": "172.21.3.15", "message": "Connected to 10.1.0.1", "event.duration": 1756467 }
---
teardown:
  - do:
      indices.delete:
        index: esql-async-test
---
'ES|QL Async':
  - do:
      esql.async_query:
        body:
          query: "FROM esql-async-test | EVAL duration_ms = ROUND(event.duration / 1000000.0, 1)"
          keep_on_completion: true
  - set: { id: id }
  - match: { columns.0.name: "@timestamp" }
  - match: { columns.0.type: "date" }
  - match: { columns.1.name: "client.ip" }
  - match: { columns.1.type: "ip" }
  - match: { columns.2.name: "event.duration" }
  - match: { columns.2.type: "long" }
  - match: { columns.3.name: "message" }
  - match: { columns.3.type: "keyword" }
  - match: { columns.4.name: "duration_ms" }
  - match: { columns.4.type: "double" }
  - do:
      esql.async_query_get: { id: $id }
  - match: { id: $id }
  - match: { columns.0.name: "@timestamp" }
  - match: { columns.0.type: "date" }
  - match: { columns.1.name: "client.ip" }
  - match: { columns.1.type: "ip" }
  - match: { columns.2.name: "event.duration" }
  - match: { columns.2.type: "long" }
  - match: { columns.3.name: "message" }
  - match: { columns.3.type: "keyword" }
  - match: { columns.4.name: "duration_ms" }
  - match: { columns.4.type: "double" }

  - do:
      esql.async_query_stop: { id: $id }
  - match: { id: $id }

  - do:
      esql.async_query_delete:
        id: $id
  - match: { acknowledged: true }