Fluent::Plugin::PgJson, a plugin for Fluentd

Output Plugin for PostgreSQL Json Type.

Json type is availble in PostgreSQL version over 9.2

Requirements

fluent-plugin-pgjson	fluentd	Ruby
>= 1.0.0	>= v1.0.0	>= 2.2
< 1.0.0	>= v0.12.0	>= 1.9

Installation

$ fluent-gem install fluent-plugin-pgjson

Schema

Specified table must have following schema:

col	type
tag_col	Text
time_col	Timestamp WITH TIME ZONE
record_col	Json

Example

CREATE TABLE fluentd (
    tag Text
    ,time Timestamptz
    ,record Json
);

JSONB?

Yes! Just define a record column as JSONB type.

CREATE TABLE fluentd (
    tag Text
    ,time Timestamptz
    ,record Jsonb
);

Configuration

Example

<match **>
  @type pgjson
  #host localhost
  #port 5432
  #sslmode prefer
  database fluentd
  table fluentd
  user postgres
  password postgres
  #time_col time
  #tag_col tag
  #record_col record
  #msgpack false
  #encoder yajl
</match>

Parameter

parameter	description	default
host	The hostname of PostgreSQL server	localhost
port	The port of PostgreSQL server	5432
sslmode	Set the sslmode to enable Eavesdropping protection/MITM protection. See PostgreSQL Documentation for more details. (disable, allow, prefer, require, verify-ca, verify-full)	prefer
database	The database name to connect
table	The table name to insert records
user	The user name to connect database	nil
password	The password to connect database	nil
time_col	The column name for the time	time
tag_col	The column name for the tag	tag
record_col	The column name for the record	record
msgpack	If true, insert records formatted as msgpack	false
encoder	JSON encoder (yajl, json)	yajl

Copyright

• Copyright (c) 2014- OKUNO Akihiro
• License
  • Apache License, version 2.0