› › ›

API обновления конвейера коннектора

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

Обновляет конфигурацию pipeline коннектора.

При создании нового коннектора конфигурация конвейера инжеста заполняется значениями по умолчанию.

Для начала работы с API коннекторов ознакомьтесь с нашим обучающим материалом.

Запрос

PUT _connector/<connector_id>/_pipeline

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

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

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

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

Тело запроса

pipeline: (Обязательно, объект) Конфигурация конвейера коннектора. Конвейер определяет, как обрабатываются данные во время загрузки в Elasticsearch.

Конфигурация конвейера должна включать следующие атрибуты:

extract_binary_content (Обязательно, булево) Флаг, указывающий, нужно ли извлекать двоичное содержимое во время загрузки.
name (Обязательно, строка) Имя конвейера инжеста.
reduce_whitespace (Обязательно, булево) Флаг, указывающий, нужно ли сокращать лишние пробелы в загружаемом содержимом.
run_ml_inference (Обязательно, булево) Флаг, указывающий, нужно ли запускать машинное обучение по загружаемому содержимому.

Коды ответов

200: Поле коннектора pipeline было успешно обновлено.
400: Параметр connector_id не был предоставлен или запрос был неверно сформирован.
404 (Отсутствующие ресурсы): Не был найден коннектор, соответствующий connector_id.

Примеры

В следующем примере обновляется свойство pipeline для коннектора с идентификатором my-connector:

resp = client.connector.update_pipeline(
    connector_id="my-connector",
    pipeline={
        "extract_binary_content": True,
        "name": "my-connector-pipeline",
        "reduce_whitespace": True,
        "run_ml_inference": True
    },
)
print(resp)

response = client.connector.update_pipeline(
  connector_id: 'my-connector',
  body: {
    pipeline: {
      extract_binary_content: true,
      name: 'my-connector-pipeline',
      reduce_whitespace: true,
      run_ml_inference: true
    }
  }
)
puts response

const response = await client.connector.updatePipeline({
  connector_id: "my-connector",
  pipeline: {
    extract_binary_content: true,
    name: "my-connector-pipeline",
    reduce_whitespace: true,
    run_ml_inference: true,
  },
});
console.log(response);

PUT _connector/my-connector/_pipeline
{
    "pipeline": {
        "extract_binary_content": true,
        "name": "my-connector-pipeline",
        "reduce_whitespace": true,
        "run_ml_inference": true
    }
}

{
    "result": "updated"
}

© 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/update-connector-pipeline-api.html