API

S3FileSystem([anon, key, secret, token, …])	Access S3 as if it were a file system.
S3FileSystem.cat(self, path)	Get the content of a file
S3FileSystem.du(self, path[, total, maxdepth])	Space used by files within a path
S3FileSystem.exists(self, path)	Is there a file at the given path
S3FileSystem.get(self, rpath, lpath[, recursive])	Copy file to local.
S3FileSystem.glob(self, path, \*\*kwargs)	Find files by glob-matching.
S3FileSystem.info(self, path[, version_id, …])	Give details of entry at path
S3FileSystem.ls(self, path[, detail, refresh])	List single “directory” with or without details
S3FileSystem.mkdir(self, path[, acl])	Create directory entry at path
S3FileSystem.mv(self, path1, path2, \*\*kwargs)	Move file from one location to another
S3FileSystem.open(self, path[, mode, …])	Return a file-like object from the filesystem
S3FileSystem.put(self, lpath, rpath[, recursive])	Upload file from local
S3FileSystem.read_block(self, fn, offset, length)	Read a block of bytes from
S3FileSystem.rm(self, path[, recursive])	Remove keys and/or bucket.
S3FileSystem.tail(self, path[, size])	Get the last size bytes from file
S3FileSystem.touch(self, path[, truncate, data])	Create empty file or truncate

S3File(s3, path[, mode, block_size, acl, …])	Open S3 key as a file.
S3File.close(self)	Close file
S3File.flush(self[, force])	Write buffered data to backend store.
S3File.info(self)	File information about this path
S3File.read(self[, length])	Return data from cache, or fetch pieces as necessary
S3File.seek(self, loc[, whence])	Set current file location
S3File.tell(self)	Current file location
S3File.write(self, data)	Write data to buffer.

S3Map(root, s3[, check, create])

Mirror previous class, not implemented in fsspec

class s3fs.core.S3FileSystem(anon=False, key=None, secret=None, token=None, use_ssl=True, client_kwargs=None, requester_pays=False, default_block_size=None, default_fill_cache=True, default_cache_type='bytes', version_aware=False, config_kwargs=None, s3_additional_kwargs=None, session=None, username=None, password=None, **kwargs)

Access S3 as if it were a file system.

This exposes a filesystem-like API (ls, cp, open, etc.) on top of S3 storage.

Provide credentials either explicitly (key=, secret=) or depend on boto’s credential methods. See botocore documentation for more information. If no credentials are available, use anon=True.

Parameters:

anon : bool (False)

Whether to use anonymous connection (public buckets only). If False, uses the key/secret given, or boto’s credential resolver (client_kwargs, environment, variables, config files, EC2 IAM server, in that order)

key : string (None)

If not anonymous, use this access key ID, if specified

secret : string (None)

If not anonymous, use this secret access key, if specified

token : string (None)

If not anonymous, use this security token, if specified

use_ssl : bool (True)

Whether to use SSL in connections to S3; may be faster without, but insecure. If use_ssl is also set in client_kwargs, the value set in client_kwargs will take priority.

s3_additional_kwargs : dict of parameters that are used when calling s3 api

methods. Typically used for things like “ServerSideEncryption”.

client_kwargs : dict of parameters for the botocore client

requester_pays : bool (False)

If RequesterPays buckets are supported.

default_block_size: int (None)

If given, the default block size value used for open(), if no specific value is given at all time. The built-in default is 5MB.

default_fill_cache : Bool (True)

Whether to use cache filling with open by default. Refer to S3File.open.

default_cache_type : string (‘bytes’)

If given, the default cache_type value used for open(). Set to “none” if no caching is desired. See fsspec’s documentation for other available cache_type values. Default cache_type is ‘bytes’.

version_aware : bool (False)

Whether to support bucket versioning. If enable this will require the user to have the necessary IAM permissions for dealing with versioned objects.

config_kwargs : dict of parameters passed to botocore.client.Config

kwargs : other parameters for core session

session : botocore Session object to be used for all connections.

This session will be used inplace of creating a new session inside S3FileSystem.

The following parameters are passed on to fsspec:

skip_instance_cache: to control reuse of instances

use_listings_cache, listings_expiry_time, max_paths: to control reuse of directory listings

Examples

>>> s3 = S3FileSystem(anon=False)  # doctest: +SKIP
>>> s3.ls('my-bucket/')  # doctest: +SKIP
['my-file.txt']

>>> with s3.open('my-bucket/my-file.txt', mode='rb') as f:  # doctest: +SKIP
...     print(f.read())  # doctest: +SKIP
b'Hello, world!'

Attributes:

transaction

A context within which files are committed together upon exit

Methods

bulk_delete(self, pathlist, \*\*kwargs)	Remove multiple keys with one call
cat(self, path)	Get the content of a file
checksum(self, path[, refresh])	Unique value for current version of file
chmod(self, path, acl, \*\*kwargs)	Set Access Control on a bucket/key
clear_instance_cache()	Clear the cache of filesystem instances.
connect(self[, refresh])	Establish S3 connection object.
copy(self, path1, path2, \*\*kwargs)	Copy within two locations in the filesystem
copy_basic(self, path1, path2, \*\*kwargs)	Copy file between locations on S3
copy_managed(self, path1, path2[, block])	Copy file between locations on S3 as multi-part
cp(self, path1, path2, \*\*kwargs)	Alias of FilesystemSpec.copy.
current()	Return the most recently created FileSystem
delete(self, path[, recursive, maxdepth])	Alias of FilesystemSpec.rm.
disk_usage(self, path[, total, maxdepth])	Alias of FilesystemSpec.du.
download(self, rpath, lpath[, recursive])	Alias of FilesystemSpec.get.
du(self, path[, total, maxdepth])	Space used by files within a path
end_transaction(self)	Finish write transaction, non-context version
exists(self, path)	Is there a file at the given path
find(self, path[, maxdepth, withdirs])	List all files below path.
from_json(blob)	Recreate a filesystem instance from JSON representation
get(self, rpath, lpath[, recursive])	Copy file to local.
get_delegated_s3pars(self[, exp])	Get temporary credentials from STS, appropriate for sending across a network.
get_mapper(self, root[, check, create])	Create key/value store based on this file-system
get_tags(self, path)	Retrieve tag key/values for the given path
getxattr(self, path, attr_name, \*\*kwargs)	Get an attribute from the metadata.
glob(self, path, \*\*kwargs)	Find files by glob-matching.
head(self, path[, size])	Get the first size bytes from file
info(self, path[, version_id, refresh])	Give details of entry at path
invalidate_cache(self[, path])	Discard any cached directory information
isdir(self, path)	Is this entry directory-like?
isfile(self, path)	Is this entry file-like?
listdir(self, path[, detail])	Alias of FilesystemSpec.ls.
ls(self, path[, detail, refresh])	List single “directory” with or without details
makedir(self, path[, create_parents])	Alias of FilesystemSpec.mkdir.
makedirs(self, path[, exist_ok])	Recursively make directories
merge(self, path, filelist, \*\*kwargs)	Create single S3 file from list of S3 files
metadata(self, path[, refresh])	Return metadata of path.
mkdir(self, path[, acl])	Create directory entry at path
mkdirs(self, path[, exist_ok])	Alias of FilesystemSpec.makedirs.
move(self, path1, path2, \*\*kwargs)	Alias of FilesystemSpec.mv.
mv(self, path1, path2, \*\*kwargs)	Move file from one location to another
open(self, path[, mode, block_size, …])	Return a file-like object from the filesystem
put(self, lpath, rpath[, recursive])	Upload file from local
put_tags(self, path, tags[, mode])	Set tags for given existing key
read_block(self, fn, offset, length[, delimiter])	Read a block of bytes from
rename(self, path1, path2, \*\*kwargs)	Alias of FilesystemSpec.mv.
rm(self, path[, recursive])	Remove keys and/or bucket.
rmdir(self, path)	Remove a directory, if empty
setxattr(self, path[, copy_kwargs])	Set metadata.
size(self, path)	Size in bytes of file
split_path(self, path)	Normalise S3 path string into bucket and key.
start_transaction(self)	Begin write transaction for deferring files, non-context version
stat(self, path, \*\*kwargs)	Alias of FilesystemSpec.info.
tail(self, path[, size])	Get the last size bytes from file
to_json(self)	JSON representation of this filesystem instance
touch(self, path[, truncate, data])	Create empty file or truncate
ukey(self, path)	Hash of file properties, to tell if it has changed
upload(self, lpath, rpath[, recursive])	Alias of FilesystemSpec.put.
url(self, path[, expires])	Generate presigned URL to access path by HTTP
walk(self, path[, maxdepth])	Return all files belows path

object_version_info

bulk_delete(self, pathlist, **kwargs)

Remove multiple keys with one call

Parameters:

pathlist : listof strings

The keys to remove, must all be in the same bucket.

checksum(self, path, refresh=False)

Unique value for current version of file

If the checksum is the same from one moment to another, the contents are guaranteed to be the same. If the checksum changes, the contents might have changed.

Parameters:

path : string/bytes

path of file to get checksum for

refresh : bool (=False)

if False, look in local cache for file details first

chmod(self, path, acl, **kwargs)

Set Access Control on a bucket/key

See http://docs.aws.amazon.com/AmazonS3/latest/dev/acl-overview.html#canned-acl

Parameters:

path : string

the object to set

acl : string

the value of ACL to apply

connect(self, refresh=True)

Establish S3 connection object.

Parameters:

refresh : bool

Whether to create new session/client, even if a previous one with the same parameters already exists. If False (default), an existing one will be used if possible

copy(self, path1, path2, **kwargs)

Copy within two locations in the filesystem

copy_basic(self, path1, path2, **kwargs)

Copy file between locations on S3

Not allowed where the origin is >5GB - use copy_managed

copy_managed(self, path1, path2, block=5368709120, **kwargs)

Copy file between locations on S3 as multi-part

block: int

The size of the pieces, must be larger than 5MB and at most 5GB. Smaller blocks mean more calls, only useful for testing.

exists(self, path)

Is there a file at the given path

get_delegated_s3pars(self, exp=3600)

Get temporary credentials from STS, appropriate for sending across a network. Only relevant where the key/secret were explicitly provided.

Parameters:

exp : int

Time in seconds that credentials are good for

Returns:

dict of parameters

get_tags(self, path)

Retrieve tag key/values for the given path

Returns:

{str: str}

getxattr(self, path, attr_name, **kwargs)

Get an attribute from the metadata.

Examples

>>> mys3fs.getxattr('mykey', 'attribute_1')  # doctest: +SKIP
'value_1'

info(self, path, version_id=None, refresh=False)

Give details of entry at path

Returns a single dictionary, with exactly the same information as ls would with detail=True.

The default implementation should calls ls and could be overridden by a shortcut. kwargs are passed on to `ls().

Some file systems might not be able to measure the file’s size, in which case, the returned dict will include 'size': None.

Returns:

dict with keys: name (full path in the FS), size (in bytes), type (file,

directory, or something else) and other FS-specific keys.

invalidate_cache(self, path=None)

Discard any cached directory information

Parameters:

path: string or None

If None, clear all listings cached else listings at or under given path.

isdir(self, path)

Is this entry directory-like?

ls(self, path, detail=False, refresh=False, **kwargs)

List single “directory” with or without details

Parameters:

path : string/bytes

location at which to list files

detail : bool (=True)

if True, each list item is a dict of file properties; otherwise, returns list of filenames

refresh : bool (=False)

if False, look in local cache for file details first

kwargs : dict

additional arguments passed on

merge(self, path, filelist, **kwargs)

Create single S3 file from list of S3 files

Uses multi-part, no data is downloaded. The original files are not deleted.

Parameters:

path : str

The final file to produce

filelist : list of str

The paths, in order, to assemble into the final file.

metadata(self, path, refresh=False, **kwargs)

Return metadata of path.

Metadata is cached unless refresh=True.

Parameters:

path : string/bytes

filename to get metadata for

refresh : bool (=False)

if False, look in local cache for file metadata first

mkdir(self, path, acl='', **kwargs)

Create directory entry at path

For systems that don’t have true directories, may create an for this instance only and not touch the real filesystem

Parameters:

path: str

location

create_parents: bool

if True, this is equivalent to makedirs

kwargs:

may be permissions, etc.

put_tags(self, path, tags, mode='o')

Set tags for given existing key

Tags are a str:str mapping that can be attached to any key, see https://docs.aws.amazon.com/awsaccountbilling/latest/aboutv2/allocation-tag-restrictions.html

This is similar to, but distinct from, key metadata, which is usually set at key creation time.

Parameters:

path: str

Existing key to attach tags to

tags: dict str, str

Tags to apply.

mode:

One of ‘o’ or ‘m’ ‘o’: Will over-write any existing tags. ‘m’: Will merge in new tags with existing tags. Incurs two remote calls.

rm(self, path, recursive=False, **kwargs)

Remove keys and/or bucket.

Parameters:

path : string

The location to remove.

recursive : bool (True)

Whether to remove also all entries below, i.e., which are returned by walk().

rmdir(self, path)

Remove a directory, if empty

setxattr(self, path, copy_kwargs=None, **kw_args)

Set metadata.

Attributes have to be of the form documented in the `Metadata Reference`_.

Parameters:

kw_args : key-value pairs like field=”value”, where the values must be

strings. Does not alter existing fields, unless the field appears here - if the value is None, delete the field.

copy_kwargs : dict, optional

dictionary of additional params to use for the underlying s3.copy_object.

Examples

>>> mys3file.setxattr(attribute_1='value1', attribute_2='value2')  # doctest: +SKIP
# Example for use with copy_args
>>> mys3file.setxattr(copy_kwargs={'ContentType': 'application/pdf'},
...     attribute_1='value1')  # doctest: +SKIP

http://docs.aws.amazon.com/AmazonS3/latest/dev/UsingMetadata.html#object-metadata

split_path(self, path) → Tuple[str, str, Union[str, NoneType]]

Normalise S3 path string into bucket and key.

Parameters:

path : string

Input path, like s3://mybucket/path/to/file

Examples

>>> split_path("s3://mybucket/path/to/file")
['mybucket', 'path/to/file', None]

>>> split_path("s3://mybucket/path/to/versioned_file?versionId=some_version_id")
['mybucket', 'path/to/versioned_file', 'some_version_id']

touch(self, path, truncate=True, data=None, **kwargs)

Create empty file or truncate

url(self, path, expires=3600, **kwargs)

Generate presigned URL to access path by HTTP

Parameters:

path : string

the key path we are interested in

expires : int

the number of seconds this signature will be good for.

walk(self, path, maxdepth=None, **kwargs)

Return all files belows path

List all files, recursing into subdirectories; output is iterator-style, like os.walk(). For a simple list of files, find() is available.

Note that the “files” outputted will include anything that is not a directory, such as links.

Parameters:

path: str

Root to recurse into

maxdepth: int

Maximum recursion depth. None means limitless, but not recommended on link-based file-systems.

kwargs: passed to ``ls``

class s3fs.core.S3File(s3, path, mode='rb', block_size=5242880, acl='', version_id=None, fill_cache=True, s3_additional_kwargs=None, autocommit=True, cache_type='bytes', requester_pays=False)

Open S3 key as a file. Data is only loaded and cached on demand.

Parameters:

s3 : S3FileSystem

botocore connection

path : string

S3 bucket/key to access

mode : str

One of ‘rb’, ‘wb’, ‘ab’. These have the same meaning as they do for the built-in open function.

block_size : int

read-ahead size for finding delimiters

fill_cache : bool

If seeking to new a part of the file beyond the current buffer, with this True, the buffer will be filled between the sections to best support random access. When reading only a few specific chunks out of a file, performance may be better if False.

acl: str

Canned ACL to apply

version_id : str

Optional version to read the file at. If not specified this will default to the current version of the object. This is only used for reading.

requester_pays : bool (False)

If RequesterPays buckets are supported.

See also

S3FileSystem.open

used to create S3File objects

Examples

>>> s3 = S3FileSystem()  # doctest: +SKIP
>>> with s3.open('my-bucket/my-file.txt', mode='rb') as f:  # doctest: +SKIP
...     ...  # doctest: +SKIP

Attributes:

closed

Methods

close(self)	Close file
commit(self)	Move from temp to final destination
discard(self)	Throw away temporary file
fileno(self, /)	Returns underlying file descriptor if one exists.
flush(self[, force])	Write buffered data to backend store.
getxattr(self, xattr_name, \*\*kwargs)	Get an attribute from the metadata.
info(self)	File information about this path
isatty(self, /)	Return whether this is an ‘interactive’ stream.
metadata(self[, refresh])	Return metadata of file.
read(self[, length])	Return data from cache, or fetch pieces as necessary
readable(self)	Whether opened for reading
readinto(self, b)	mirrors builtin file’s readinto method
readline(self)	Read until first occurrence of newline character
readlines(self)	Return all data, split by the newline character
readuntil(self[, char, blocks])	Return data between current position and first occurrence of char
seek(self, loc[, whence])	Set current file location
seekable(self)	Whether is seekable (only in read mode)
setxattr(self[, copy_kwargs])	Set metadata.
tell(self)	Current file location
truncate()	Truncate file to size bytes.
url(self, \*\*kwargs)	HTTP URL to read this file (if it already exists)
writable(self)	Whether opened for writing
write(self, data)	Write data to buffer.

readinto1
writelines

commit(self)

Move from temp to final destination

discard(self)

Throw away temporary file

getxattr(self, xattr_name, **kwargs)

Get an attribute from the metadata. See getxattr().

Examples

>>> mys3file.getxattr('attribute_1')  # doctest: +SKIP
'value_1'

metadata(self, refresh=False, **kwargs)

Return metadata of file. See metadata().

Metadata is cached unless refresh=True.

setxattr(self, copy_kwargs=None, **kwargs)

Set metadata. See setxattr().

Examples

>>> mys3file.setxattr(attribute_1='value1', attribute_2='value2')  # doctest: +SKIP

url(self, **kwargs)

HTTP URL to read this file (if it already exists)

s3fs.mapping.S3Map(root, s3, check=False, create=False)

Mirror previous class, not implemented in fsspec

class s3fs.utils.ParamKwargsHelper(s3)

Utility class to help extract the subset of keys that an s3 method is actually using

Parameters:

s3 : boto S3FileSystem

Methods

filter_dict

class s3fs.utils.SSEParams(server_side_encryption=None, sse_customer_algorithm=None, sse_customer_key=None, sse_kms_key_id=None)

Methods

to_kwargs