Code examples for Amazon Managed Workflows for Apache Airflow (original) (raw)
DocumentationAmazon Managed Workflows for Apache AirflowUser Guide
This guide contains code samples, including DAGs and custom plugins, that you can use on an Amazon Managed Workflows for Apache Airflow environment. For more examples of using Apache Airflow with AWS services, see thedags directory in the Apache Airflow GitHub repository.
Samples
- Using a DAG to import variables in the CLI
- Creating an SSH connection using the SSHOperator
- Using a secret key in AWS Secrets Manager for an Apache Airflow Snowflake connection
- Using a DAG to write custom metrics in CloudWatch
- Aurora PostgreSQL database cleanup on an Amazon MWAA environment
- Exporting environment metadata to CSV files on Amazon S3
- Using a secret key in AWS Secrets Manager for an Apache Airflow variable
- Using a secret key in AWS Secrets Manager for an Apache Airflow connection
- Creating a custom plugin with Oracle
- Creating a custom plugin that generates runtime environment variables
- Changing a DAG's timezone on Amazon MWAA
- Refreshing a CodeArtifact token
- Creating a custom plugin with Apache Hive and Hadoop
- Creating a custom plugin for Apache Airflow PythonVirtualenvOperator
- Invoking DAGs with a Lambda function
- Invoking DAGs in different Amazon MWAA environments
- Using Amazon MWAA with Amazon RDS for Microsoft SQL Server
- Using Amazon MWAA with Amazon EMR
- Using Amazon MWAA with Amazon EKS
- Connecting to Amazon ECS using the ECSOperator
- Using dbt with Amazon MWAA
- AWS blogs and tutorials
AWS blogs and tutorials
Tutorial: Automate managing your own environment endpoints
Import variables DAG
Did this page help you? - Yes
Thanks for letting us know we're doing a good job!
If you've got a moment, please tell us what we did right so we can do more of it.
Did this page help you? - No
Thanks for letting us know this page needs work. We're sorry we let you down.
If you've got a moment, please tell us how we can make the documentation better.