› › ›

API задач ожидания кластера

Возвращает изменения на уровне кластера, которые еще не были выполнены.

Запрос

GET /_cluster/pending_tasks

Предварительные условия

Если включены функции безопасности Elasticsearch, вам необходимо иметь право monitor или manage права кластера для использования этого API.

Описание

API задач ожидания кластера возвращает список любых изменений на уровне кластера (например, создание индекса, обновление отображения, выделение или сбой фрагмента), которые еще не были выполнены.

Этот API возвращает список ожидающих обновлений состояния кластера. Они отличаются от задач, сообщаемых API управления задачами, которые включают периодические задачи и задачи, инициированные пользователем, такие как статистика узлов, запросы поиска или запросы создания индексов. Однако, если задача, инициированная пользователем, например, команда создания индекса, вызывает обновление состояния кластера, активность этой задачи может быть сообщена как API задач, так и API задач ожидания кластера.

Параметры пути

local: (Необязательно, логическое значение) Если true, запрос извлекает информацию только с локального узла. По умолчанию используется false, что означает извлечение информации с узла-мастера.
master_timeout: (Необязательно, единицы измерения времени) Время ожидания узла-мастера. Если узел-мастер недоступен до истечения срока ожидания, запрос завершается ошибкой. По умолчанию используется 30s. Также можно установить значение -1, чтобы указать, что запрос никогда не должен истекать.

Тело ответа

tasks: (объект) Список ожидающих задач.
insert_order: (целое число) Число, представляющее момент добавления задачи в очередь задач.
priority: (строка) Приоритет задачи ожидания. Действительные приоритеты в порядке убывания приоритета: IMMEDIATE > URGENT > HIGH > NORMAL > LOW > LANGUID.
source: (строка) Общее описание задачи кластера, которое может включать причину и источник.
executing: (булево) Истина или ложь, указывающие, выполняется ли в данный момент ожидающая задача.
time_in_queue_millis: (целое число) Время в миллисекундах, прошедшее с момента ожидания выполнения задачи.
time_in_queue: (строка) Время, прошедшее с момента ожидания выполнения задачи.

Примеры

Обычно запрос возвращает пустой список, поскольку изменения на уровне кластера происходят быстро. Однако, если в очереди есть задачи, ответ будет примерно таким:

{
   "tasks": [
      {
         "insert_order": 101,
         "priority": "URGENT",
         "source": "create-index [foo_9], cause [api]",
         "executing" : true,
         "time_in_queue_millis": 86,
         "time_in_queue": "86ms"
      },
      {
         "insert_order": 46,
         "priority": "HIGH",
         "source": "shard-started ([foo_2][1], node[tMTocMvQQgGCkj7QDHl3OA], [P], s[INITIALIZING]), reason [after recovery from shard_store]",
         "executing" : false,
         "time_in_queue_millis": 842,
         "time_in_queue": "842ms"
      },
      {
         "insert_order": 45,
         "priority": "HIGH",
         "source": "shard-started ([foo_2][0], node[tMTocMvQQgGCkj7QDHl3OA], [P], s[INITIALIZING]), reason [after recovery from shard_store]",
         "executing" : false,
         "time_in_queue_millis": 858,
         "time_in_queue": "858ms"
      }
  ]
}

© 2023-2025 Elasticsearch
As of September 2024, Elasticsearch is available under a choice of three licenses: the Server Side Public License (SSPL), the Elastic License, or the AGPLv3 (OSI approved).
Elasticsearch and the Elasticsearch logo are trademarks of Elasticsearch B.V., registered in the U.S. and in other countries.
https://www.elastic.co/guide/en/elasticsearch/reference/8.17/cluster-pending.html