| :py:mod:`airflow.providers.amazon.aws.example_dags.example_dms` |
| =============================================================== |
| |
| .. py:module:: airflow.providers.amazon.aws.example_dags.example_dms |
| |
| .. autoapi-nested-parse:: |
| |
| Note: DMS requires you to configure specific IAM roles/permissions. For more information, see |
| https://docs.aws.amazon.com/dms/latest/userguide/CHAP_Security.html#CHAP_Security.APIRole |
| |
| |
| |
| Module Contents |
| --------------- |
| |
| |
| Functions |
| ~~~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.amazon.aws.example_dags.example_dms.set_up |
| airflow.providers.amazon.aws.example_dags.example_dms.clean_up |
| |
| |
| |
| Attributes |
| ~~~~~~~~~~ |
| |
| .. autoapisummary:: |
| |
| airflow.providers.amazon.aws.example_dags.example_dms.S3_BUCKET |
| airflow.providers.amazon.aws.example_dags.example_dms.ROLE_ARN |
| airflow.providers.amazon.aws.example_dags.example_dms.PROJECT_NAME |
| airflow.providers.amazon.aws.example_dags.example_dms.RDS_ENGINE |
| airflow.providers.amazon.aws.example_dags.example_dms.RDS_PROTOCOL |
| airflow.providers.amazon.aws.example_dags.example_dms.RDS_USERNAME |
| airflow.providers.amazon.aws.example_dags.example_dms.RDS_PASSWORD |
| airflow.providers.amazon.aws.example_dags.example_dms.RDS_INSTANCE_NAME |
| airflow.providers.amazon.aws.example_dags.example_dms.RDS_DB_NAME |
| airflow.providers.amazon.aws.example_dags.example_dms.DMS_REPLICATION_INSTANCE_NAME |
| airflow.providers.amazon.aws.example_dags.example_dms.DMS_REPLICATION_TASK_ID |
| airflow.providers.amazon.aws.example_dags.example_dms.SOURCE_ENDPOINT_IDENTIFIER |
| airflow.providers.amazon.aws.example_dags.example_dms.TARGET_ENDPOINT_IDENTIFIER |
| airflow.providers.amazon.aws.example_dags.example_dms.TABLE_NAME |
| airflow.providers.amazon.aws.example_dags.example_dms.TABLE_HEADERS |
| airflow.providers.amazon.aws.example_dags.example_dms.SAMPLE_DATA |
| airflow.providers.amazon.aws.example_dags.example_dms.TABLE_DEFINITION |
| airflow.providers.amazon.aws.example_dags.example_dms.TABLE_MAPPINGS |
| airflow.providers.amazon.aws.example_dags.example_dms.create_task |
| |
| |
| .. py:data:: S3_BUCKET |
| |
| |
| |
| |
| .. py:data:: ROLE_ARN |
| |
| |
| |
| |
| .. py:data:: PROJECT_NAME |
| :annotation: = DmsDemo |
| |
| |
| |
| .. py:data:: RDS_ENGINE |
| :annotation: = postgres |
| |
| |
| |
| .. py:data:: RDS_PROTOCOL |
| :annotation: = postgresql |
| |
| |
| |
| .. py:data:: RDS_USERNAME |
| :annotation: = username |
| |
| |
| |
| .. py:data:: RDS_PASSWORD |
| :annotation: = rds_password |
| |
| |
| |
| .. py:data:: RDS_INSTANCE_NAME |
| |
| |
| |
| |
| .. py:data:: RDS_DB_NAME |
| |
| |
| |
| |
| .. py:data:: DMS_REPLICATION_INSTANCE_NAME |
| |
| |
| |
| |
| .. py:data:: DMS_REPLICATION_TASK_ID |
| |
| |
| |
| |
| .. py:data:: SOURCE_ENDPOINT_IDENTIFIER |
| |
| |
| |
| |
| .. py:data:: TARGET_ENDPOINT_IDENTIFIER |
| |
| |
| |
| |
| .. py:data:: TABLE_NAME |
| |
| |
| |
| |
| .. py:data:: TABLE_HEADERS |
| :annotation: = ['apache_project', 'release_year'] |
| |
| |
| |
| .. py:data:: SAMPLE_DATA |
| :annotation: = [['Airflow', '2015'], ['OpenOffice', '2012'], ['Subversion', '2000'], ['NiFi', '2006']] |
| |
| |
| |
| .. py:data:: TABLE_DEFINITION |
| |
| |
| |
| |
| .. py:data:: TABLE_MAPPINGS |
| |
| |
| |
| |
| .. py:function:: set_up() |
| |
| |
| .. py:function:: clean_up() |
| |
| |
| .. py:data:: create_task |
| |
| |
| |
| |