› › ›

API синхронизации задач подключения

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

Заявляет о задаче синхронизации подключения.

Конечная точка _claim не предназначена для непосредственного управления подключениями пользователями. Она предназначена для поддержки реализации сервисов, которые используют протокол подключения для связи с Elasticsearch.

Чтобы начать работу с Connector API, ознакомьтесь с нашим руководством.

Запрос

PUT _connector/_sync_job/<connector_sync_job_id>/_claim

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

Для синхронизации данных с помощью собственных подключений вам необходимо развернуть сервис подключения Elastic на вашей собственной инфраструктуре. Этот сервис автоматически запускается в Elastic Cloud для управляемых Elastic подключений.
Параметр connector_sync_job_id должен ссылаться на существующую задачу синхронизации подключения.

Описание

Заявляет о задаче синхронизации подключения. Этот действие обновляет статус задачи на in_progress и устанавливает метки времени last_seen и started_at на текущее время. Кроме того, он может установить свойство sync_cursor для задачи синхронизации.

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

connector_sync_job_id: (Обязательно, строка)

Тело запроса

worker_hostname: (Обязательно, строка) Имя хоста текущей системы, которая будет выполнять задачу.
sync_cursor: (Необязательно, Объект) Объект курсора из последней задачи синхронизации инкрементально. Он должен ссылаться на поле sync_cursor в состоянии подключения, для которого выполняется работа.

Коды ответов

200: Задача синхронизации подключения успешно заявлена.
404: Не найдено задачи синхронизации подключения, соответствующей connector_sync_job_id.

Примеры

В следующем примере заявлена задача синхронизации подключения с идентификатором my-connector-sync-job-id:

resp = client.perform_request(
    "PUT",
    "/_connector/_sync_job/my-connector-sync-job-id/_claim",
    headers={"Content-Type": "application/json"},
    body={
        "worker_hostname": "some-machine"
    },
)
print(resp)

const response = await client.transport.request({
  method: "PUT",
  path: "/_connector/_sync_job/my-connector-sync-job-id/_claim",
  body: {
    worker_hostname: "some-machine",
  },
});
console.log(response);

PUT _connector/_sync_job/my-connector-sync-job-id/_claim
{
  "worker_hostname": "some-machine"
}

© 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/claim-connector-sync-job-api.html