Sha256: 2baf208a4df01ba4fa051c4a8037cc06748334b6622bc489d248551143b11818
Contents?: true
Size: 1.27 KB
Versions: 5
Compression:
Stored size: 1.27 KB
Contents
# fluent-plugin-sqs-poll fluent input plugin poll data from AWS SQS ## Install ```bash gem install fluent-plugin-sqs-poll ``` ## IMPORTANT **SQS Poll uses AWS SDK v2, it will cause conflict with other AWS plugins that uses v1 version 'aws-sdk' gem. It will however be compatible with AWS plugins that uses 'aws-sdk-v1' gem.** ## Configuration If either **aws_access_key** or **aws_secret_key** is missing, it will automatically fall back to use IAM role for access control. ``` <source> type sqs_poll aws_access_key {optional: your_aws_access_key} aws_secret_key {optional: your_aws_secret_key} tag {required: tag} sqs_url {required: SQS_url} max_number_of_messages {optional: # of messges poll at a time, default: 1} </source> ``` ## Usage When messages are pulled off SQS queue, it's stored in key **body** of the emmitted output. If your SQS message is in a known format, you probably want to use in conjunction with **fluent-plugin-parser**. For example, if your message from SQS is in JSON format, then you would want to do: ``` <source> type sqs_poll tag sqs.message sqs_url https://sqs.us-east-1.amazonaws.com/123456789/some_queue max_number_of_messages 10 </source> <match sqs.message> type parser remove_prefix sqs format json key_name body </match> ```
Version data entries
5 entries across 5 versions & 1 rubygems