write

in lib/fluent/plugin/out_kinesis_streams.rb [42:54]

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

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