AWS | Kestra

AWS

AWS plugin for Kestra

S3

Tasks that manage Amazon Simple Storage Service (S3) buckets and objects.

SNS

Tasks that publish notifications to Amazon Simple Notification Service (SNS) topics for pub/sub fanout or SMS, email, Lambda, and SQS targets, with support for custom message attributes.

CloudFormation

Tasks that create, update, or delete AWS CloudFormation stacks and optionally wait for stack operations to finish, returning stack outputs for downstream use.

AWS Authentication

Tasks that generate authentication material for AWS services, such as short-lived tokens to access Amazon EKS clusters.

Eventbridge

Tasks that put events on Amazon EventBridge buses with custom detail payloads so routing rules can fan them out to downstream AWS or SaaS targets.

SQS

Tasks that publish to or consume from Amazon Simple Queue Service (SQS), including polling and real-time triggers.

ECR

Tasks that fetch an Amazon ECR authorization token for Docker or OCI registry logins, useful before building or pulling images in workflows.

Glue

Tasks that control AWS Glue jobs: start runs with arguments, monitor their status, stop executions, and fetch job metadata to orchestrate serverless Spark ETL pipelines.

EMR

Tasks that orchestrate Amazon EMR and EMR Serverless workloads: create or delete clusters, submit steps, start job runs, and optionally wait for completion so Spark or Hadoop pipelines can be managed from Kestra.

Kinesis

Tasks that write batches of records to Amazon Kinesis Data Streams with partition keys for high-throughput, real-time ingestion pipelines.

Athena

Tasks that run Amazon Athena SQL queries against data in S3 or federated sources, writing results to an S3 output location and optionally fetching rows.

Dynamodb

Tasks that read and write Amazon DynamoDB tables: put, get, or delete individual items and run query or scan operations with expression attributes.

Lambda

Tasks that invoke AWS Lambda functions with optional JSON payloads, capture response bodies or logs, and emit metrics about execution time and payload size for serverless workflows.

AWS CLI

Tasks that run AWS CLI commands (inside a container by default), reuse Kestra credentials and environment variables, and capture stdout or files produced by the CLI.

CloudWatch

Tasks that push custom metrics, query recent CloudWatch metric statistics, and trigger flows when metric queries return data.

Apache Cassandra

Tasks that integrate Apache Cassandra into Kestra workflows for querying and event-driven triggers.

Data

Git

Tasks that clone, fetch, and interact with Git repositories.

InfrastructureBusiness

MongoDB

Tasks that query and manipulate MongoDB collections.

Data

AWS

AWS plugin for Kestra

S3

SNS

CloudFormation

AWS Authentication

Eventbridge

SQS

ECR

Glue

EMR

Kinesis

Athena

Dynamodb

Lambda

AWS CLI

CloudWatch

How to use this plugin

Create automations with AWS Plugins

Govern cloud infrastructure with Kestra Assets — automated S3 bucket provisioning by team

Register S3 JSON files as governed datasets and curate them with DuckDB

Query data from Druid and load it to Redshift

More Plugins in this Category

Apache Cassandra

Git

MongoDB

2.1.5

AWS AWS plugin for Kestra

S3

SNS

CloudFormation

AWS Authentication

Eventbridge

SQS

ECR

Glue

EMR

Kinesis

Athena

Dynamodb

Lambda

AWS CLI

CloudWatch

How to use this plugin

Create automations with AWS Plugins

Govern cloud infrastructure with Kestra Assets — automated S3 bucket provisioning by team

Register S3 JSON files as governed datasets and curate them with DuckDB

Query data from Druid and load it to Redshift

More Plugins in this Category

Apache Cassandra

Git

MongoDB

2.1.5

AWS

AWS plugin for Kestra