Skip to content
Fluent output plugin for Amazon SNS
Branch: master
Clone or download
Latest commit fd37fdd May 7, 2019
Type Name Latest commit message Commit time
Failed to load latest commit information.
examples Initial commit Mar 7, 2014
lib/fluent/plugin Version 0.1.0 May 7, 2019
.gitignore Initial commit Mar 7, 2014
Gemfile Initial commit Mar 7, 2014 Version 0.1.0 May 7, 2019
LICENSE.txt Initial commit Mar 7, 2014 Version 0.1.0 May 7, 2019
Rakefile Initial commit Mar 7, 2014
fluent-plugin-amazon_sns.gemspec Merge remote-tracking branch 'cosmo0920/migrate-v0.14' May 7, 2019


Fluent output plugin to send messages to Amazon SNS.


fluent-plugin-amazon_sns Fluentd Ruby
>= 0.1.0 >= v0.14.15 >= 2.1
< 0.1.0 >= v0.10.0 >= 1.9


gem install fluent-plugin-amazon_sns


<match sns.**>
  type amazon_sns

  flush_interval 1s

  # Optional if you have AWS_* environment variables set up (via IAM Role etc.)
  aws_access_key_id AWS_ACCESS_KEY_ID
  aws_secret_access_key AWS_SECRET_ACCESS_KEY
  aws_region AWS_REGION # (e.g. ap-northeast-1)

  # One of the following options must be enabled to map topics

  ## 1) Fixed string
  topic_name MyTopic

  ## 2) Map fluent tags
  ## sns.App.MyTopic -> 'App-MyTopic'
  topic_map_tag true
  remove_tag_prefix sns

  ## 3) Map fluent message key
  ## maps 'topic' key in the message
  topic_map_key topic

  # SNS Message Subject, either fixed string or map message key
  subject_key SUBJECT_KEY


Difference with fluent-plugin-sns

  • Topic names are dynamically configurable, rather than static
  • Buffered output


  1. Fork it ( )
  2. Create your feature branch (git checkout -b my-new-feature)
  3. Commit your changes (git commit -am 'Add some feature')
  4. Push to the branch (git push origin my-new-feature)
  5. Create new Pull Request


Tatsuhiko Miyagawa

The code is heavily inspired by: ixixi/fluent-plugin-sns and norikra/fluent-plugin-norikra.

You can’t perform that action at this time.