Plugin

Arg	Description	Type
query	Source for rows to upload.	StoredQuery (required)
threads	How many threads to use.	int64
index	The name of the index to upload to. If not specified ensure a column is named ‘_index’.	string
type	The type of the index to upload to.	string
chunk_size	The number of rows to send at the time.	int64
addresses	A list of Elasticsearch nodes to use.	list of string
username	Username for HTTP Basic Authentication.	string
password	Password for HTTP Basic Authentication.	string
cloud_id	Endpoint for the Elastic Cloud Service.	string
api_key	Base64-encoded token for authorization; if set, overrides username and password.	string
wait_time	Batch elastic upload this long (2 sec).	int64
pipeline	Pipeline for uploads	string
disable_ssl_security	Disable ssl certificate verifications (deprecated in favor of SkipVerify).	bool
skip_verify	Disable ssl certificate verifications.	bool
root_ca	As a better alternative to disable_ssl_security, allows root ca certs to be added here.	string
max_memory_buffer	How large we allow the memory buffer to grow to while we are trying to contact the Elastic server (default 100mb).	uint64
action	Either index or create. For data streams this must be create.	string
secret	Alternatively use a secret from the secrets service. Secret must be of type ‘AWS S3 Creds’	string

Required permissions: NETWORK

Description

Upload rows to elastic.

This uses the Elastic bulk upload API to push arbitrary rows to elastic. The query specified in query will be run and each row it emits will be uploaded as a separate event to Elastic.

You can either specify the elastic index explicitly using the index parameter or provide an _index column in the query itself to send the row to a different index each time.