The `apache-airflow-providers-amazon` package extends Apache Airflow by providing operators, hooks, and sensors for seamless integration with various Amazon Web Services (AWS). It enables orchestrating workflows involving services like Amazon S3, Redshift, EMR, SQS, and more. The provider is actively maintained by the Apache Airflow community with frequent releases, typically every few weeks.
pip install apache-airflow-providers-amazonVerified import paths — ran on the pinned version, not inferred.
This example demonstrates a basic Airflow DAG that uses the `S3CopyObjectOperator` from the Amazon provider to copy an object between two S3 buckets. Ensure you have an Airflow connection named `aws_default` configured with appropriate AWS credentials and permissions, or set AWS environment variables.
Upgrade your Apache Airflow environment to at least version 2.11.0. Consult the Airflow documentation for upgrade paths.
Update existing DAGs to use `cloudformation_parameters` instead of `params` for these operators.
Use the `impersonation_chain` parameter for impersonation in affected operators.
Refer to the latest Airflow AWS provider documentation for recommended connection configurations, preferring `endpoint_url` in `extra` where applicable.
Always explicitly include a `--constraint` statement in your `requirements.txt` for MWAA environments.
It is recommended to use a Python version officially supported by the library, typically Python 3.8-3.12, until full Python 3.13 compatibility is confirmed.
Update the import statement to: 'from airflow.providers.amazon.aws.transfers.s3_to_s3 import S3ToS3Operator'
Change the import to: 'from airflow.providers.amazon.aws.hooks.s3 import S3Hook'
Use the correct import: 'from airflow.providers.amazon.aws.operators.emr_create_job_flow import EmrCreateJobFlowOperator'
Install the 'apache-airflow-providers-common-sql' package and import using: 'from airflow.providers.common.sql.operators.sql import SQLExecuteQueryOperator'
Install the 'apache-airflow-providers-common-sql' package and import using: 'from airflow.providers.common.sql.transfers.s3_to_sql import S3ToSqlOperator'