Class: Fluent::KinesisFirehoseOutput
Constant Summary
collapse
- RequestType =
:firehose
- BatchRequestLimitCount =
500
- BatchRequestLimitSize =
4 * 1024 * 1024
Fluent::KinesisHelper::API::MaxRecordSize
Instance Method Summary
collapse
included, #size_of_values
fluentd_v0_12?, #multi_workers_ready?
included
#client, included
Instance Method Details
29
30
31
32
33
34
35
36
37
|
# File 'lib/fluent/plugin/out_kinesis_firehose.rb', line 29
def configure(conf)
super
if @append_new_line
org_data_formatter = @data_formatter
@data_formatter = ->(tag, time, record) {
org_data_formatter.call(tag, time, record) + "\n"
}
end
end
|
39
40
41
42
43
|
# File 'lib/fluent/plugin/out_kinesis_firehose.rb', line 39
def format(tag, time, record)
format_for_api do
[@data_formatter.call(tag, time, record)]
end
end
|
#write(chunk) ⇒ Object
45
46
47
48
49
50
51
52
53
54
55
|
# File 'lib/fluent/plugin/out_kinesis_firehose.rb', line 45
def write(chunk)
write_records_batch(chunk) do |batch|
records = batch.map{|(data)|
{ data: data }
}
client.put_record_batch(
delivery_stream_name: @delivery_stream_name,
records: records,
)
end
end
|