Skip to content

Mount Athena S3 Results Node

Data/DataFusion/Databases

Mount Athena S3 Results

Mount Parquet files from an Athena query result location in S3. Supports explicit credentials or environment variables (including Lambda IAM roles).

df_mount_athena_querydata
Inputs10
Outputs2
Security exposure4/10
Packagedata

Ratings

Scores range from 0 to 10. Higher values mean more impact, exposure, or operational weight.

SecurityAttack surface and exposure impact.
4/10Medium
PrivacyPotential sensitivity of processed data.
5/10Medium
PerformanceRuntime or resource pressure.
2/10High
GovernancePolicy, audit, or compliance impact.
3/10High
ReliabilityOperational stability considerations.
1/10High
CostExternal or compute cost impact.
5/10Medium

Input Pins

10

Input

Execution
exec_in

Trigger execution

Session

Struct
session

DataFusion session to register the table in

DataFusionSessionDataFusionSession1 fields
cache_keystringrequired

S3 Path

String
s3_path

S3 path to Athena query results (e.g., s3://bucket/athena-results/query-id/)

Region

String
region

AWS region

Default us-east-1

Credential Mode

String
credential_mode

How to authenticate: 'explicit' (access keys), 'environment' (env vars/Lambda IAM role/profile via AWS_PROFILE env var)

Default explicit
explicitenvironment

Access Key ID

String
access_key_id

AWS access key ID (only used when credential_mode is 'explicit')

Secret Access Key

String
secret_access_key

AWS secret access key (only used when credential_mode is 'explicit')

Session Token

String
session_token

Optional AWS session token for temporary credentials

Table Name

String
table_name

Name to register the table as in DataFusion

Format

String
format

File format (parquet, csv)

Default parquet

Output Pins

2

Done

Execution
exec_out

Table registered successfully

Session

Struct
session_out

DataFusion session with registered table

DataFusionSessionDataFusionSession1 fields
cache_keystringrequired

Node Info

Internal name
df_mount_athena_query
Category
Data/DataFusion/Databases
Version
2