Request
Send a request to an OpenSearch cluster.
Send a request to an OpenSearch cluster.
Send a request to an OpenSearch cluster.
type: "io.kestra.plugin.opensearch.Request"Examples
Inserting a document in an index using POST request.
id: opensearch_request
namespace: company.team
tasks:
- id: request_post
type: io.kestra.plugin.opensearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "POST"
endpoint: "my_index/_doc/john"
body:
name: "john"
Searching for documents using GET request.
id: opensearch_request
namespace: company.team
tasks:
- id: request_get
type: io.kestra.plugin.opensearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "GET"
endpoint: "my_index/_search"
parameters:
q: "name:"John Doe""
Deleting document using DELETE request.
id: opensearch_request
namespace: company.team
tasks:
- id: request_delete
type: io.kestra.plugin.opensearch.Request
connection:
hosts:
- "http://localhost:9200"
method: "DELETE"
endpoint: "my_index/_doc/<_id>"
Properties
connection*RequiredNon-dynamic
The connection properties.
io.kestra.plugin.opensearch.OpensearchConnection
List of HTTP OpenSearch servers.
Must be an URI like https://opensearch.com: 9200 with scheme and port.
Basic auth configuration.
io.kestra.plugin.opensearch.OpensearchConnection-BasicAuth
Basic auth password.
Basic auth username.
List of HTTP headers to be send on every request.
Must be a string with key value separated with : , ex: Authorization: Token XYZ.
Sets the path's prefix for every request used by the HTTP client.
For example, if this is set to /my/path, then any client request will become /my/path/ + endpoint.
In essence, every request's endpoint is prefixed by this pathPrefix.
The path prefix is useful for when OpenSearch is behind a proxy that provides a base path or a proxy that requires all paths to start with '/'; it is not intended for other purposes and it should not be supplied in other scenarios.
Whether the REST client should return any response containing at least one warning header as a failure.
Trust all SSL CA certificates.
Use this if the server is using a self signed SSL certificate.
endpoint*Requiredstring
The path of the request (without scheme, host, port, or prefix).
bodyobject
The full body.
Can be a JSON string or raw Map that will be converted to json.
methodstring
GETCONNECTCUSTOMDELETEGETHEADOPTIONSPATCHPOSTPUTTRACEThe http method to use.
parametersobject
Query string parameters.
routingstring
Controls the shard routing of the request.
Using this value to hash the shard and not the id.
