Amazon MWAA 的代码示例

本指南包含可在 Amazon MWAA 环境中使用的代码示例，包括 DAG 和自定义插件。有关在 AWS 服务中使用 Apache Airflow 的更多示例，请参阅 Apache Airflow GitHub 存储库中的 dags 目录。

样本

• 使用 DAG 在 CLI 中导入变量

• 使用 SSHOperator 创建 SSH 连接

• 使用 AWS Secrets Manager 中的密钥进行 Apache Airflow Snowflake 连接

• 使用 DAG 在 CloudWatch 中编写自定义指标

• 在 Amazon MWAA 环境中清理 Aurora PostgreSQL 数据库

• 将环境元数据导出到 Amazon S3 上的 CSV 文件

• 为 Apache Airflow 变量使用 AWS Secrets Manager 中的密钥

• 使用 AWS Secrets Manager 中的密钥进行 Apache Airflow 连接

• 使用 Oracle 创建自定义插件

• 在 Amazon MWAA 上更改 DAG 的时区

• 刷新 CodeArtifact 令牌

• 使用 Apache Hive 和 Hadoop 创建自定义插件

• 为 Apache Airflow PythonVirtualenvOperator 创建自定义插件

• 使用 Lambda 函数调用 DAG

• 在不同的 Amazon MWAA 环境中调用 DAG

• 将 Amazon RDS for Microsoft SQL Server 与 Amazon MWAA 一起使用

• 将 Amazon MWAA 与 Amazon EKS 一起使用

• 使用 ECSOperator 连接 Amazon ECS

• 在 Amazon MWAA 中使用 dbt

• AWS 博客和教程

AWS 博客和教程

• 使用 Amazon EKS 和 Apache Airflow v2.x 的 Amazon MWAA