apache_beam.io.aws.clients.s3.messages module

class apache_beam.io.aws.clients.s3.messages.GetRequest(bucket, object)[source]

S3 request object for Get command

class apache_beam.io.aws.clients.s3.messages.UploadResponse(upload_id)[source]

S3 response object for StartUpload command

class apache_beam.io.aws.clients.s3.messages.UploadRequest(bucket, object, mime_type)[source]

S3 request object for StartUpload command

class apache_beam.io.aws.clients.s3.messages.UploadPartRequest(bucket, object, upload_id, part_number, bytes)[source]

S3 request object for UploadPart command

class apache_beam.io.aws.clients.s3.messages.UploadPartResponse(etag, part_number)[source]

S3 response object for UploadPart command

class apache_beam.io.aws.clients.s3.messages.CompleteMultipartUploadRequest(bucket, object, upload_id, parts)[source]

S3 request object for UploadPart command

class apache_beam.io.aws.clients.s3.messages.ListRequest(bucket, prefix, continuation_token=None)[source]

S3 request object for List command

class apache_beam.io.aws.clients.s3.messages.ListResponse(items, next_token=None)[source]

S3 response object for List command

class apache_beam.io.aws.clients.s3.messages.Item(etag, key, last_modified, size, mime_type=None)[source]

An item in S3

class apache_beam.io.aws.clients.s3.messages.DeleteRequest(bucket, object)[source]

S3 request object for Delete command

class apache_beam.io.aws.clients.s3.messages.DeleteBatchRequest(bucket, objects)[source]: Bases: object

class apache_beam.io.aws.clients.s3.messages.DeleteBatchResponse(deleted, failed, errors)[source]: Bases: object

class apache_beam.io.aws.clients.s3.messages.CopyRequest(src_bucket, src_key, dest_bucket, dest_key)[source]: Bases: object

exception apache_beam.io.aws.clients.s3.messages.S3ClientError(message=None, code=None)[source]: Bases: Exception