Rethrottle API

Rethrottle API

다음 API를 사용하면 이미 실행 중인 _reindex, _update_by_query, _delete_by_query 작업의 requests_per_second를 동적으로 변경할 수 있어요.

도입 버전 1.0

엔드포인트

POST /_delete_by_query/{task_id}/_rethrottle
POST /_reindex/{task_id}/_rethrottle
POST /_update_by_query/{task_id}/_rethrottle

경로 파라미터

쿼리 파라미터

예제 요청: 실행 중인 delete by query 태스크 재스로틀

POST /_delete_by_query/<YOUR_TASK_ID>/_rethrottle?requests_per_second=10

예제 요청: 실행 중인 reindex 태스크 재스로틀

POST /_reindex/<YOUR_TASK_ID>/_rethrottle?requests_per_second=20

예제 요청: 실행 중인 update by query 태스크 재스로틀

POST /_update_by_query/<YOUR_TASK_ID>/_rethrottle?requests_per_second=5

예제 응답

다음 응답은 활성 update_by_query 태스크에 대한 세부 정보를 제공해요:

{
  "nodes": {
    "bvv8SKpiRhOhF9_Bu8gZ7w": {
      "name": "opensearch-node1",
      "transport_address": "172.18.0.4:9300",
      "host": "172.18.0.4",
      "ip": "172.18.0.4:9300",
      "roles": [
        "cluster_manager",
        "data",
        "ingest",
        "remote_cluster_client"
      ],
      "attributes": {
        "shard_indexing_pressure_enabled": "true"
      },
      "tasks": {
        "bvv8SKpiRhOhF9_Bu8gZ7w:640": {
          "node": "bvv8SKpiRhOhF9_Bu8gZ7w",
          "id": 640,
          "type": "transport",
          "action": "indices:data/write/update/byquery",
          "status": {
            "total": 4785,
            "updated": 1000,
            "created": 0,
            "deleted": 0,
            "batches": 1,
            "version_conflicts": 0,
            "noops": 0,
            "retries": {
              "bulk": 0,
              "search": 0
            },
            "throttled_millis": 0,
            "requests_per_second": 50,
            "throttled_until_millis": 2146
          },
          "description": "update-by-query [test-rethrottle] updated with Script{type=inline, lang='painless', idOrCode='ctx._source.new_field = 'updated'', options={}, params={}}",
          "start_time_in_millis": 1751310547697,
          "running_time_in_nanos": 9567425129,
          "cancellable": true,
          "cancelled": false,
          "headers": {
            "X-Opaque-Id": "1b911516-44cd-4920-8c1e-79368ea7cdfd"
          },
          "resource_stats": {
            "average": {
              "cpu_time_in_nanos": 0,
              "memory_in_bytes": 0
            },
            "total": {
              "cpu_time_in_nanos": 0,
              "memory_in_bytes": 0
            },
            "min": {
              "cpu_time_in_nanos": 0,
              "memory_in_bytes": 0
            },
            "max": {
              "cpu_time_in_nanos": 0,
              "memory_in_bytes": 0
            },
            "thread_info": {
              "thread_executions": 0,
              "active_threads": 0
            }
          }
        }
      }
    }
  }
}

응답 본문 필드

응답은 재스로틀된 작업에 대한 태스크 및 노드 수준의 자세한 정보를 제공해요.

출처: 문서