Search
Send a search request.
Get all documents from a search request and store it as outputs.
type: "io.kestra.plugin.opensearch.Search"id: opensearch_search
namespace: company.team
tasks:
- id: search
type: io.kestra.plugin.opensearch.Search
connection:
hosts:
- "http://localhost:9200"
indexes:
- "my_index"
request:
query:
term:
name:
value: 'john'
NOThe connection properties.
YESJSONCBORJSONSMILEYAMLThe content type of value.
YESFETCHSTOREFETCHFETCH_ONENONEThe way you want to store the data.
FETCH_ONE output the first row, FETCH output all the rows, STORE store all rows in a file, NONE do nothing.
YESThe OpenSearch indices.
Default to all indices.
YESThe OpenSearch value.
Can be a JSON string. In this case, the contentType will be used or a raw Map.
YESControls the shard routing of the request.
Using this value to hash the shard and not the id.
Map containing the first row of fetched data.
Only populated if using fetchType=FETCH_ONE.
List containing the fetched data.
Only populated if using fetchType=FETCH.
The size of the rows fetched.
The total of the rows fetched without pagination.
uriThe URI of the stored data.
Only populated if using fetchType=STORE.
YESList of HTTP OpenSearch servers.
Must be an URI like https://opensearch.com: 9200 with scheme and port.
NOBasic auth configuration.
YESList of HTTP headers to be send on every request.
Must be a string with key value separated with : , ex: Authorization: Token XYZ.
YESSets 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.
YESYESYESBasic auth password.
YESBasic auth username.