trevorrowe

import com.amazonaws.services.s3.transfer.TransferManager;
import com.amazonaws.services.s3.transfer.TransferManagerBuilder;
import java.nio.file.Paths;
 
public class TransferManagerUploadExample {
    private static final String BUCKET = <bucket>;
    private static final String KEY = <key>;
    private static final String FILE_PATH = <path>;
 
    public static void main(String[] args) throws InterruptedException {

trevorrowe

#!/usr/bin/env ruby

require 'aws-sdk'

# This example produces empty http responses, but gives some general structure and guiance.
class DummyHttpHandler < Seahorse::Client::Handler

  def call(context)

    context.http_request.endpoint    # HTTP or HTTPS URI

trevorrowe

# using EC2 client
ec2 = Aws::EC2::Client.new
ec2.describe_instances.each_page do |resp|
  resp.reservations.each do |reservation|
    reservation.instances.each do |intsance|
      puts instance.instance_id
    end
  end
end

trevorrowe

require 'aws-sdk'
require 'pathname'

class ProgressIO

  def initialize(io)
    @io = io
    @bytes_read = 0
    @listeners = []
  end

trevorrowe

require 'net/http'
require 'logger'

req = Net::HTTP::Put.new('/', { 'expect' => '100-continue' })
req.body = 'data'

http = Net::HTTP.new('localhost', 3000)
http.continue_timeout = 1
http.set_debug_output(Logger.new($stdout))
http.request(req)

trevorrowe

require 'net/http'
require 'logger'

req = Net::HTTP::Put.new('/', { 'expect' => '100-continue' })
req.body = 'data'

http = Net::HTTP.new('localhost', 3000)
http.continue_timeout = 1
http.set_debug_output(Logger.new($stdout))
http.request(req)

trevorrowe

# This example server accepts a simple PUT request with the 'Excpect: 100-continue'
# header. It alternates between the following two responses:
#
# * 100 Continue, accepting the body, then 200 OK
# * 403 Forbidden, not accepting the body
#

require 'socket'

server = TCPServer.new('localhost', 3000)

trevorrowe

class ConditionalRaisePlugin < Seahorse::Client::Plugin

  class Handler < Seahorse::Client::Handler
    
    def call(context)
      response = @handler.call(context)
      conditional_raise(response.error, context.config.errors_to_ignore)
      response
    end

trevorrowe

class ProgressIO

  def initialize(io)
    @io = io
  end

  def read(bytes = nil, output_buffer = nil)
    puts bytes
    @io.read(bytes, output_buffer)
  end

trevorrowe

pattern = "[aws] [:client_class] operation=:operation duration=:time retries=:retries error=:error_class\n"
Aws.config[:log_formatter] = Seahorse::Client::Logging::Formatter.new(pattern)

# success
[aws] [Aws::S3::Client] operation=list_buckets duration=0.602057 retries=0 error=

# error
[aws] [Aws::S3::Client] operation=head_bucket duration=1.100552 retries=0 error=Aws::S3::Errors::Forbidden