Fluentd output plugin for inserting data to BigObject using AVRO
Add this line to your application's Gemfile:
gem 'fluent-plugin-bigobject_avro'And then execute:
$ bundle
Or install it yourself as:
$ gem install fluent-plugin-bigobject_avro
Configure BigObject URL and the table/column to be mapped in BigObject
# send data to BigObject using avro by providing schema_file in each table
# BigObject will create the table if it does not already exist.
<match bo.insert_avro.*>
type bigobject
log_level info
# specify the bigobject host/port to connect to
bigobject_hostname 192.168.59.103
bigobject_port 9091
remove_tag_prefix bo.insert_avro.
flush_interval 60s
<table>
pattern customer
schema_file /fluentd/input/avsc/Customer_binary.avsc
</table>
</match>
The gem is available as open source under the terms of the MIT License.