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

class apache_beam.io.aws.clients.s3.messages.GetRequest(bucket, object)

S3 request object for Get command

class apache_beam.io.aws.clients.s3.messages.UploadResponse(upload_id)

S3 response object for StartUpload command

class apache_beam.io.aws.clients.s3.messages.UploadRequest(bucket, object, mime_type)

S3 request object for StartUpload command

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

S3 request object for UploadPart command

class apache_beam.io.aws.clients.s3.messages.UploadPartResponse(etag, part_number)

S3 response object for UploadPart command

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

S3 request object for UploadPart command

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

S3 request object for List command

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

S3 response object for List command

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

An item in S3

class apache_beam.io.aws.clients.s3.messages.DeleteRequest(bucket, object)

S3 request object for Delete command

class apache_beam.io.aws.clients.s3.messages.DeleteBatchRequest(bucket, objects)

class apache_beam.io.aws.clients.s3.messages.DeleteBatchResponse(deleted, failed, errors)

class apache_beam.io.aws.clients.s3.messages.CopyRequest(src_bucket, src_key, dest_bucket, dest_key)

exception apache_beam.io.aws.clients.s3.messages.S3ClientError(message=None, code=None)

Bases: exceptions.Exception