* Creating PR with first file. Signed-off-by: carolxob <[email protected]> * Adding newly created files to PR. Signed-off-by: carolxob <[email protected]> * Reorganized files and added appropriate metadata to map ToC correctly. Signed-off-by: carolxob <[email protected]> * Moved Authoring pipelines page. Signed-off-by: carolxob <[email protected]> * Minor ToC updates. Signed-off-by: carolxob <[email protected]> * Minor ToC updates to Sources section for Data Prepper. Signed-off-by: carolxob <[email protected]> * Updated Buffers section under Data Prepper. Signed-off-by: carolxob <[email protected]> * Minor update to otelmetricssource. Signed-off-by: carolxob <[email protected]> * Restructured ToC in Processors section for Data Prepper. Signed-off-by: carolxob <[email protected]> * Minor filename change. Signed-off-by: carolxob <[email protected]> * Adjustments to metadata in ToC. Signed-off-by: carolxob <[email protected]> * Minor edit. Signed-off-by: carolxob <[email protected]> * Fixed nav order in metadata. Signed-off-by: carolxob <[email protected]> * Minor edit. Signed-off-by: carolxob <[email protected]> * Minor update top metadata for ToC. Signed-off-by: carolxob <[email protected]> * Adjustmenets to Toc order. Signed-off-by: carolxob <[email protected]> * Minor adjustments to ToC metadata. Signed-off-by: carolxob <[email protected]> * Minor adjustments to Sinks section. Signed-off-by: carolxob <[email protected]> * Adjustements to high level ToC. Signed-off-by: carolxob <[email protected]> * Minor adjustement to Pipelines.md Signed-off-by: carolxob <[email protected]> * Minor update. Signed-off-by: carolxob <[email protected]> * Slight reorganization. Removed two placeholder pages for now. Signed-off-by: carolxob <[email protected]> * Removed a page and replaced with pipelines content. Signed-off-by: carolxob <[email protected]> * Minor changes/additions to content for placeholder pages. Signed-off-by: carolxob <[email protected]> * Minor update to page link. Signed-off-by: carolxob <[email protected]> * Minor adjustments to ToC metadata. Signed-off-by: carolxob <[email protected]> * Minor edits. Signed-off-by: carolxob <[email protected]> * Removed /clients from redirects to correct nav order. Signed-off-by: carolxob <[email protected]> * Minor edits. Signed-off-by: carolxob <[email protected]> * Minor adjustments to ToC metadata. Signed-off-by: carolxob <[email protected]> * Minor adjustments. Signed-off-by: carolxob <[email protected]> * Minor adjustment ot metadata. Signed-off-by: carolxob <[email protected]> * TOC link fixes Signed-off-by: Naarcha-AWS <[email protected]> * Changed page name. Signed-off-by: carolxob <[email protected]> * Corrected references to Peer Forwarder. Signed-off-by: carolxob <[email protected]> * Renamed Data Prepper folder. Signed-off-by: carolxob <[email protected]> * Minor updates to phrasing and capitalization. Signed-off-by: carolxob <[email protected]> * Minor phrasing update. Signed-off-by: carolxob <[email protected]> * Minor phrasing update. Signed-off-by: carolxob <[email protected]> * Minor change. Signed-off-by: carolxob <[email protected]> * Minor change to change S3 Source to S3Source. Signed-off-by: carolxob <[email protected]> * Updated references to peer forwarder and changed capitalization. Signed-off-by: carolxob <[email protected]> * Updated capitalization for peer forwarder. Signed-off-by: carolxob <[email protected]> * Made edits based on doc review feedback. Signed-off-by: carolxob <[email protected]> * Update to one word. Signed-off-by: carolxob <[email protected]> --------- Signed-off-by: carolxob <[email protected]> Signed-off-by: Naarcha-AWS <[email protected]> Co-authored-by: Naarcha-AWS <[email protected]>
4.0 KiB
4.0 KiB
layout, title, parent, grand_parent, nav_order
| layout | title | parent | grand_parent | nav_order |
|---|---|---|---|---|
| default | s3 | Sources | Pipelines | 20 |
s3
Overview
This is a source plugin that reads events from Amazon Simple Storage Service (Amazon S3) objects.
| Option | Required | Type | Description |
|---|---|---|---|
| notification_type | Yes | String | Must be sqs |
| compression | No | String | The compression algorithm to apply: none, gzip, or automatic. Default is none. |
| codec | Yes | Codec | The codec to apply. Must be newline, json, or csv. |
| sqs | Yes | sqs | The Amazon Simple Queue Service (Amazon SQS) configuration. See sqs for details. |
| aws | Yes | aws | The AWS configuration. See aws for details. |
| on_error | No | String | Determines how to handle errors in Amazon SQS. Can be either retain_messages or delete_messages. If retain_messages, then Data Prepper will leave the message in the SQS queue and try again. This is recommended for dead-letter queues. If delete_messages, then Data Prepper will delete failed messages. Default is retain_messages. |
| buffer_timeout | No | Duration | The timeout for writing events to the Data Prepper buffer. Any events that the S3Source cannot write to the buffer in this time will be discarded. Default is 10 seconds. |
| records_to_accumulate | No | Integer | The number of messages that accumulate before writing to the buffer. Default is 100. |
| metadata_root_key | No | String | Base key for adding S3 metadata to each Event. The metadata includes the key and bucket for each S3 object. Defaults to s3/. |
| disable_bucket_ownership_validation | No | Boolean | If true, the S3Source will not attempt to validate that the bucket is owned by the expected account. The expected account is the same account that owns the SQS queue. Defaults to false. |
sqs
The following parameters allow you to configure usage for Amazon SQS in the S3Source plugin.
| Option | Required | Type | Description |
|---|---|---|---|
| queue_url | Yes | String | The URL of the Amazon SQS queue from which messages are received. |
| maximum_messages | No | Integer | The maximum number of messages to receive from the SQS queue in any single request. Default is 10. |
| visibility_timeout | No | Duration | The visibility timeout to apply to messages read from the SQS queue. This should be set to the amount of time that Data Prepper may take to read all the S3 objects in a batch. Default is 30s. |
| wait_time | No | Duration | The time to wait for long polling on the SQS API. Default is 20s. |
| poll_delay | No | Duration | A delay to place between reading and processing a batch of SQS messages and making a subsequent request. Default is 0s. |
aws
| Option | Required | Type | Description |
|---|---|---|---|
| region | No | String | The AWS Region to use for credentials. Defaults to standard SDK behavior to determine the Region. |
| sts_role_arn | No | String | The AWS Security Token Service (AWS STS) role to assume for requests to Amazon SQS and Amazon S3. Defaults to null, which will use the standard SDK behavior for credentials. |
file
Source for flat file input.
| Option | Required | Type | Description |
|---|---|---|---|
| path | Yes | String | Path to the input file (e.g. logs/my-log.log). |
| format | No | String | Format of each line in the file. Valid options are json or plain. Default is plain. |
| record_type | No | String | The record type to store. Valid options are string or event. Default is string. If you would like to use the file source for log analytics use cases like grok, set this option to event. |
pipeline
Source for reading from another pipeline.
| Option | Required | Type | Description |
|---|---|---|---|
| name | Yes | String | Name of the pipeline to read from. |
stdin
Source for console input. Can be useful for testing. No options.