temporalio.contrib.aws.s3driver.aioboto3._Aioboto3StorageDriverClient

class documentation

class _Aioboto3StorageDriverClient(S3StorageDriverClient): (source)

Constructor: _Aioboto3StorageDriverClient(client)

View In Hierarchy

Adapter that wraps an aioboto3 S3 client as an S3StorageDriverClient.

Internally delegates to upload_fileobj for uploads (which handles multipart automatically for objects above the multipart threshold) and get_object for downloads.

Warning

This API is experimental.

Method __init__ Wrap an aioboto3 S3 client.
Method describe Region of the wrapped aioboto3 client, surfaced in driver error messages to short-circuit the most common silent 403 misconfiguration.
Async Method get_object Download bytes via aioboto3's get_object.
Async Method object_exists Check existence via aioboto3's head_object.
Async Method put_object Upload data via aioboto3's upload_fileobj.
Instance Variable _client Undocumented
def __init__(self, client: S3Client): (source)

Wrap an aioboto3 S3 client.

Parameters
client:S3ClientAn aioboto3 S3 client, typically obtained from aioboto3.Session().client("s3").
def describe(self) -> Mapping[str, str]: (source)

Region of the wrapped aioboto3 client, surfaced in driver error messages to short-circuit the most common silent 403 misconfiguration.

async def get_object(self, *, bucket: str, key: str) -> bytes: (source)

Download bytes via aioboto3's get_object.

async def object_exists(self, *, bucket: str, key: str) -> bool: (source)

Check existence via aioboto3's head_object.

async def put_object(self, *, bucket: str, key: str, data: bytes): (source)

Upload data via aioboto3's upload_fileobj.

_client = (source)

Undocumented