
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
accessKeyIdstring
catalogstring
compatibilityModebooleanstring
endpointOverridestring
fetchTypestring
Default
STOREPossible Values
STOREFETCHFETCH_ONENONEforcePathStylebooleanstring
regionstring
secretKeyIdstring
sessionTokenstring
skipHeaderbooleanstring
Default
truestsEndpointOverridestring
stsRoleArnstring
stsRoleExternalIdstring
stsRoleSessionDurationstring
Default
PT15MFormat
durationstsRoleSessionNamestring
Outputs
queryExecutionIdstring
rowobject
rowsarray
sizeinteger
uristring
Format
uriMetrics
data.scanned.bytescounter
Unit
bytesengine.execution.durationcounter
Unit
millisecondsfetch.rowscounter
Unit
rowsquery.planning.durationcounter
Unit
millisecondsquery.queue.durationcounter
Unit
millisecondsservice.processing.durationcounter
Unit
millisecondstotal.execution.durationcounter
Unit
millisecondstotal.rowscounter
Unit
rows