Fluentd output plugin to publish events to an amqp broker.
Events are published one by one using the Fluentd tag as the routing key, in JSON format like:
{ "key": "fluentd-tag", "timestamp": "fluentd-timestamp", "payload": "event-payload" }Add this line to your application's Gemfile:
gem 'fluent-plugin-amqp2'
And then execute:
$ bundle
Or install it yourself as:
$ gem install fluent-plugin-amqp2
<match pattern>
type amqp
# Set broker host and port
host localhost
port 5672
# Set user and password for authentication
user guest
password guest
# Configure amqp entities vhost, exchange id and type
vhost /
exchange my_exchange
exchange_type topic
exchange_durable false # optionally set exchange durability - default is false.
payload_only false # optional - default is false. if true, only the payload will be sent. if false, data format is { "key" => tag, "timestamp" => time, "payload" => record }.
content_type application/octet-stream # optional - default is application/octet-stream. some amqp consumers will expect application/json.
</match>
- Fork it
- Create your feature branch (
git checkout -b my-new-feature) - Commit your changes (
git commit -am 'Add some feature') - Push to the branch (
git push origin my-new-feature) - Create new Pull Request
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent