fluent-plugin-cassandra-json

Fluentd output plugin to insert json data to cassandra.

This plugin support complex data type like collection.

Installation

RubyGems

$ gem install fluent-plugin-cassandra-json

Bundler

Add following line to your Gemfile:

gem "fluent-plugin-cassandra-json"

And then execute:

$ bundle

Plugin helpers

• inject

• formatter

• See also: Output Plugin Overview

Configuration

hosts (array) (required)

The entire list of cluster members for initial lookup

port (integer) (optional)

Cassandra native protocol port

Default value: 9042.

username (string) (optional)

Cluster username

password (string) (optional)

Cluster password

cluster_options (hash) (optional)

Other Cluster option parameters

Default value: {}.

consistency (enum) (optional)

Set consistency level

Available values: any, one, two, three, quorum, all, local_quorum, each_quorum, serial, local_serial, local_one

Default value: one.

keyspace (string) (required)

Target keyspace name

table (string) (required)

Target table name

if_not_exists (bool) (optional)

Use IF NOT EXIST option on INSERT

ttl (integer) (optional)

Use TTL option on INSERT

skip_invalid_rows (bool) (optional)

Treat request as success, even if invalid rows exist

Default value: true.

<format> section (optional) (multiple)

@type () (optional)

Default value: json.

Copyright

• Copyright(c) 2018- joker1007
• License
  • Apache License, Version 2.0