Fluent::Plugin::PostgresReplicator, a plugin for Fluentd
Fluentd input plugin to track insert/update event from PostgreSQL.
# requirements
$ apt-get install libpq-dev
$ gem install fluent-plugin-postgres-replicator
<source>
type postgres_replicator
host localhost
username pipeline
password pipeline
database pipeline
sql SELECT hour, project, total_pages from wiki_stats;
primary_keys hour,project
interval 1m
tag replicator.pipeline.wiki_stats.${event}.${primary_keys}
</source>
Bug reports and pull requests are welcome.
- Copyright (c) 2016 innossh
- Apache License, Version 2.0