write

in lib/fluent/plugin/out_kinesis_firehose.rb [45:57]

• 12 lines of code
• 1 McCabe index (conditional complexity)

      def write(chunk)
        delivery_stream_name = extract_placeholders(@delivery_stream_name, chunk)
        write_records_batch(chunk, delivery_stream_name) do |batch|
          records = batch.map{|(data)|
            { data: data }
          }
          client.put_record_batch(
            delivery_stream_name: delivery_stream_name,
            records: records,
          )
        end
      end