bulk_response_process

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 #

NameTypeDescription
invalid_queuestringName of the queue that saves an invalid request. It is mandatory.
failure_queuestringName of the queue that saves a failed request. It is mandatory.
save_partial_success_requestsboolWhether to save partially successful requests in bulk requests. The default value is false.
success_queuestringQueue that saves partially successful requests in the bulk requests
continue_on_errorboolWhether to continue to execute subsequent filters after an error occurs on a bulk request. The default value is false.
message_truncate_sizeintTruncation length of a bulk request error log. The default value is 1024.
safety_parseboolWhether to use a secure bulk metadata parsing method. The default value is true.
doc_buffer_sizeintBuffer size when an insecure bulk metadata parsing method is adopted. The default value is 256 * 1024.
tag_on_successarraySpecified tag to be attached to request context after all bulk requests are processed.
tag_on_errorarraySpecified tag to be attached to request context after an error occurs on a request.
tag_on_partialarraySpecified tag to be attached to request context after requests in a bulk request are partially executed successfully.
tag_on_failurearraySpecified tag to be attached to request context after some requests in a bulk request fail (retry is supported).
tag_on_invalidarraySpecified tag to be attached to request context after an invalid request error occurs.
success_flowstringFlow executed upon successful request
invalid_flowstringFlow executed upon invalid request
failure_flowstringFlow executed upon failed request
Edit Edit this page