本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
Amazon MWAA 的代码示例
本指南包含可在 Amazon MWAA 环境中使用的代码示例,包括 DAG 和自定义插件。有关在 Amazon 服务中使用 Apache Airflow 的更多示例,请参阅 Apache Airflow GitHub 存储库中的 example_dags
示例
- 使用 DAG 在 CLI 中导入变量
- 使用 SSHOperator 创建 SSH 连接
- 使用 Amazon Secrets Manager 中的密钥进行 Apache Airflow Snowflake 连接
- 使用 DAG 在 CloudWatch 中编写自定义指标
- 在 Amazon MWAA 环境中清理 Aurora PostgreSQL 数据库
- 将环境元数据导出到 Amazon S3 上的 CSV 文件
- 为 Apache Airflow 变量使用 Amazon Secrets Manager 中的密钥
- 使用 Amazon 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 EMR 的 Amazon MWAA
- 将 Amazon MWAA 与 Amazon EKS 一起使用
- 使用 ECSOperator 连接 Amazon ECS
- 在 Amazon MWAA 中使用 dbt
- Amazon 博客和教程