Logstash

class elasticsearch_serverless.client.LogstashClient(client: BaseClient)
delete_pipeline(*, id: str, error_trace: bool | None = None, filter_path: str | Sequence[str] | None = None, human: bool | None = None, pretty: bool | None = None) ObjectApiResponse[Any]

Delete a Logstash pipeline. Delete a pipeline that is used for Logstash Central Management. If the request succeeds, you receive an empty response with an appropriate status code.

https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-logstash-delete-pipeline

Parameters:

id – An identifier for the pipeline.

get_pipeline(*, id: str | Sequence[str] | None = None, error_trace: bool | None = None, filter_path: str | Sequence[str] | None = None, human: bool | None = None, pretty: bool | None = None) ObjectApiResponse[Any]

Get Logstash pipelines. Get pipelines that are used for Logstash Central Management.

https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-logstash-get-pipeline

Parameters:

id – A comma-separated list of pipeline identifiers.

put_pipeline(*, id: str, pipeline: Mapping[str, Any] | None = None, body: Mapping[str, Any] | None = None, error_trace: bool | None = None, filter_path: str | Sequence[str] | None = None, human: bool | None = None, pretty: bool | None = None) ObjectApiResponse[Any]

Create or update a Logstash pipeline.

Create a pipeline that is used for Logstash Central Management. If the specified pipeline exists, it is replaced.

https://www.elastic.co/docs/api/doc/elasticsearch/operation/operation-logstash-put-pipeline

Parameters:
  • id – An identifier for the pipeline.

  • pipeline