interloper-aws
AWS integration for interloper: an S3Destination that stores asset data in
an Amazon S3 bucket, and the AWSConnection that holds the credentials.
S3Destination is an ObjectStoreDestination, the same base as the Cloud
Storage destination in interloper-google-cloud, so the two behave
identically: one object per partition in a hive-partitioned layout, Parquet
(the default), JSONL or CSV, the partition column in the path only, and each
object's row count stored as row_count user metadata.
s3://{bucket}/{prefix}/{dataset}/{table}/data.{ext}
s3://{bucket}/{prefix}/{dataset}/{table}/{column}={partition}/data.{ext}
Usage
import interloper as il
from interloper_aws import AWSConnection, S3Destination
destination = S3Destination(
connection=AWSConnection(region="eu-central-1"),
bucket="acme-lake",
prefix="raw",
format="parquet",
)
source = Shop(destinations=destination)
Credentials
The connection takes an access key pair (access_key_id,
secret_access_key, plus session_token for temporary credentials) and a
region, defaulting to eu-central-1. Each field also loads from the
standard environment variables: AWS_ACCESS_KEY_ID,
AWS_SECRET_ACCESS_KEY, AWS_SESSION_TOKEN and AWS_REGION.
Leave the key pair empty and boto3's default credential chain applies: environment, shared config files, then the instance or pod role (an EC2 instance profile, EKS IRSA or Pod Identity). In a cluster, that means no stored secret at all: grant the workload's role access to the bucket.
The connection's check calls STS GetCallerIdentity, which needs no IAM
permission, so a failing check means the credentials themselves are wrong.
The bucket picker calls ListBuckets.
Permissions
The destination needs, on the bucket and its objects:
s3:PutObjectto writes3:GetObjectto read, and to count objects written withoutrow_countmetadatas3:ListBucketfor partition row countss3:ListAllMyBucketsfor the bucket picker only
Notes
ListObjectsV2 returns no user metadata, so partition row counts issue one
HeadObject per listed object. That is still no download: the count comes
from the row_count metadata stamped at write time. Objects written by other
tools, without that metadata, are downloaded and counted.
Metadata
Release files for interloper-aws 0.100.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| interloper_aws-0.100.0.tar.gz | 4.4 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| interloper_aws-0.100.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 10.7 kB
Release files / interloper_aws-0.100.0.tar.gz
| Download URL | interloper_aws-0.100.0.tar.gz |
|---|---|
| Size | 4.4 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
ea9f84d45c8346cc17b15d33f958604f477bf6d8a06eb5a480ba019d2471f897
|
|
BLAKE2b-256 checksum How to use checksums |
3f02089d14ad26320676af60dc532fa61e2ea5cf12997f2670a118a266bdd01c
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
uv/0.12.22 {"installer":{"name":"uv","version":"0.12.22","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
|
Release files / interloper_aws-0.100.0-py3-none-any.whl
| Download URL | interloper_aws-0.100.0-py3-none-any.whl |
|---|---|
| Size | 6.3 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
f94b4b0e7f9422bc9e95b709abd0b3175ef7e993513a907d7488e2bd8063dcc4
|
|
BLAKE2b-256 checksum How to use checksums |
b3fbfb7b349093a97443faf63a0608ab4e16da980761c65fd8172653843c450d
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
Yes |
| Uploaded via |
uv/0.12.22 {"installer":{"name":"uv","version":"0.12.22","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"Ubuntu","version":"24.04","id":"noble","libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":true}
|
