bulk_response_process #
Description #
The bulk_response_process filter is used to process bulk requests of Elasticsearch.
Configuration Example #
A simple example is as follows:
flow:
- name: bulk_response_process
filter:
- bulk_response_process:
success_queue: "success_queue"
tag_on_success: ["commit_message_allowed"]
Parameter Description #
Name | Type | Description |
---|---|---|
invalid_queue | string | Name of the queue that saves an invalid request. It is mandatory. |
failure_queue | string | Name of the queue that saves a failed request. It is mandatory. |
save_partial_success_requests | bool | Whether to save partially successful requests in bulk requests. The default value is false . |
success_queue | string | Queue that saves partially successful requests in the bulk requests |
continue_on_error | bool | Whether to continue to execute subsequent filters after an error occurs on a bulk request. The default value is false . |
message_truncate_size | int | Truncation length of a bulk request error log. The default value is 1024 . |
safety_parse | bool | Whether to use a secure bulk metadata parsing method. The default value is true . |
doc_buffer_size | int | Buffer size when an insecure bulk metadata parsing method is adopted. The default value is 256 * 1024 . |
tag_on_success | array | Specified tag to be attached to request context after all bulk requests are processed. |
tag_on_error | array | Specified tag to be attached to request context after an error occurs on a request. |
tag_on_partial | array | Specified tag to be attached to request context after requests in a bulk request are partially executed successfully. |
tag_on_failure | array | Specified tag to be attached to request context after some requests in a bulk request fail (retry is supported). |
tag_on_invalid | array | Specified tag to be attached to request context after an invalid request error occurs. |
success_flow | string | Flow executed upon successful request |
invalid_flow | string | Flow executed upon invalid request |
failure_flow | string | Flow executed upon failed request |