Skip to main content

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:PutObject to write
  • s3:GetObject to read, and to count objects written without row_count metadata
  • s3:ListBucket for partition row counts
  • s3:ListAllMyBuckets for 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.109.0

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for interloper-aws 0.109.0
File Size Uploaded
interloper_aws-0.109.0.tar.gz 4.4 kB Details

Built distribution (wheel)

Table of built distributions (wheels) for interloper-aws 0.109.0
File Interpreter ABI Platform
interloper_aws-0.109.0-py3-none-any.whl Python 3 none any Details

Total release size: 10.7 kB

Release files / interloper_aws-0.109.0.tar.gz

Download URL interloper_aws-0.109.0.tar.gz
Size 4.4 kB
Tags Source
SHA-256 checksum
How to use checksums
91f26a88b73cd996ff787dcacc9b2c5fb02cb352e4beb8431bea3a6bdf8e76b1
BLAKE2b-256 checksum
How to use checksums
dc56bc826a1ccfbe1fe0d62b149c17f9afb02512f4ba2e7e502fdba626c4f32f
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
Yes
Uploaded via uv/0.12.23 {"installer":{"name":"uv","version":"0.12.23","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.109.0-py3-none-any.whl

Download URL interloper_aws-0.109.0-py3-none-any.whl
Size 6.3 kB
Tags Python 3
SHA-256 checksum
How to use checksums
ec44dddeb43718eefe33585e1b43a87eff26a8f6e0f928b4c5679349d1ee0d0e
BLAKE2b-256 checksum
How to use checksums
42af26904c9403a8f6c36bef2d0d52675c6ba2cb29b61993efb877d653e26b10
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
Yes
Uploaded via uv/0.12.23 {"installer":{"name":"uv","version":"0.12.23","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}
Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page