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 json
</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) Starting from v1.0.3, yajl is no longer available and internally defaults to json	json

Copyright

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