Query
Query
yaml
type: "io.kestra.plugin.aws.athena.Query"Examples
yaml
id: aws_athena_query
namespace: company.team
tasks:
- id: query
type: io.kestra.plugin.aws.athena.Query
accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
secretKeyId: "{{ secret('AWS_SECRET_KEY_ID') }}"
region: "eu-central-1"
database: my_database
outputLocation: s3://some-s3-bucket
query: |
select * from cloudfront_logs limit 10
Properties
database *Requiredstring
outputLocation *Requiredstring
query *Requiredstring
accessKeyId string
catalog string
compatibilityMode booleanstring
endpointOverride string
fetchType string
Default
STOREPossible Values
STOREFETCHFETCH_ONENONEforcePathStyle booleanstring
region string
secretKeyId string
sessionToken string
skipHeader booleanstring
Default
truestsEndpointOverride string
stsRoleArn string
stsRoleExternalId string
stsRoleSessionDuration string
Default
PT15MFormat
durationstsRoleSessionName string
Outputs
queryExecutionId string
row object
rows array
size integer
uri string
Format
uriMetrics
data.scanned.bytes counter
Unit
bytesengine.execution.duration counter
Unit
millisecondsfetch.rows counter
Unit
rowsquery.planning.duration counter
Unit
millisecondsquery.queue.duration counter
Unit
millisecondsservice.processing.duration counter
Unit
millisecondstotal.execution.duration counter
Unit
millisecondstotal.rows counter
Unit
rows