Update the connector pipeline Beta; Added in 8.12.0

PUT /_connector/{connector_id}/_pipeline
Api key auth Basic auth Bearer auth

When you create a new connector, the configuration of an ingest pipeline is populated with default settings.

Path parameters

  • connector_id string Required

    The unique identifier of the connector to be updated

application/json

Body Required

  • pipeline object Required
    Hide pipeline attributes Show pipeline attributes object
    • extract_binary_content boolean Required
    • name string Required
    • reduce_whitespace boolean Required
    • run_ml_inference boolean Required

Responses

  • 200 application/json
    Hide response attribute Show response attribute object
    • result string Required

      Values are created, updated, deleted, not_found, or noop.
PUT /_connector/{connector_id}/_pipeline 
PUT _connector/my-connector/_pipeline { "pipeline": { "extract_binary_content": true, "name": "my-connector-pipeline", "reduce_whitespace": true, "run_ml_inference": true } }
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 }, )
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, }, });
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 } } )
$resp = $client->connector()->updatePipeline([ "connector_id" => "my-connector", "body" => [ "pipeline" => [ "extract_binary_content" => true, "name" => "my-connector-pipeline", "reduce_whitespace" => true, "run_ml_inference" => true, ], ], ]);
curl -X PUT -H "Authorization: ApiKey $ELASTIC_API_KEY" -H "Content-Type: application/json" -d '{"pipeline":{"extract_binary_content":true,"name":"my-connector-pipeline","reduce_whitespace":true,"run_ml_inference":true}}' "$ELASTICSEARCH_URL/_connector/my-connector/_pipeline"
client.connector().updatePipeline(u -> u .connectorId("my-connector") .pipeline(p -> p .extractBinaryContent(true) .name("my-connector-pipeline") .reduceWhitespace(true) .runMlInference(true) ) );
Request example 
{ "pipeline": { "extract_binary_content": true, "name": "my-connector-pipeline", "reduce_whitespace": true, "run_ml_inference": true } }
Response examples (200) 
{ "result": "updated" }