`airflow.providers.amazon.aws.example_dags.example_dms`¶

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¶

`S3_BUCKET`
`ROLE_ARN`
`PROJECT_NAME`
`RDS_ENGINE`
`RDS_PROTOCOL`
`RDS_USERNAME`
`RDS_PASSWORD`
`RDS_INSTANCE_NAME`
`RDS_DB_NAME`
`DMS_REPLICATION_INSTANCE_NAME`
`DMS_REPLICATION_TASK_ID`
`SOURCE_ENDPOINT_IDENTIFIER`
`TARGET_ENDPOINT_IDENTIFIER`
`TABLE_NAME`
`TABLE_HEADERS`
`SAMPLE_DATA`
`TABLE_DEFINITION`
`TABLE_MAPPINGS`
`create_db_instance`

airflow.providers.amazon.aws.example_dags.example_dms.PROJECT_NAME = DmsDemo[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.RDS_ENGINE = postgres[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.RDS_PROTOCOL = postgresql[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.RDS_USERNAME = username[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.RDS_PASSWORD = rds_password[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.RDS_INSTANCE_NAME[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.DMS_REPLICATION_INSTANCE_NAME[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.DMS_REPLICATION_TASK_ID[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.SOURCE_ENDPOINT_IDENTIFIER[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.TARGET_ENDPOINT_IDENTIFIER[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.TABLE_HEADERS = ['apache_project', 'release_year'][source]¶

airflow.providers.amazon.aws.example_dags.example_dms.SAMPLE_DATA = [['Airflow', '2015'], ['OpenOffice', '2012'], ['Subversion', '2000'], ['NiFi', '2006']][source]¶

airflow.providers.amazon.aws.example_dags.example_dms.TABLE_DEFINITION[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.TABLE_MAPPINGS[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.create_sample_table()[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.create_dms_assets()[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.delete_dms_assets()[source]¶

airflow.providers.amazon.aws.example_dags.example_dms.create_db_instance[source]¶