temporalio.contrib.aws.s3driver.S3StorageDriverClient

class documentation

class S3StorageDriverClient(ABC): (source)

Abstract base class for S3 object operations.

Implementations must support put_object and get_object. Multipart upload handling (if needed) is an internal concern of each implementation.

Warning

This API is experimental.

Async Method	`get_object`	Download and return the bytes stored at the given S3 bucket and key.
Async Method	`object_exists`	Return `True` if an object exists at the given bucket and key.
Async Method	`put_object`	Upload data to the given S3 bucket and key.

@abstractmethod

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

Download and return the bytes stored at the given S3 bucket and key.

@abstractmethod

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

Return True if an object exists at the given bucket and key.

@abstractmethod

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

Upload data to the given S3 bucket and key.