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

Functions

set_up()

clean_up()

Attributes

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_task

airflow.providers.amazon.aws.example_dags.example_dms.S3_BUCKET[source]
airflow.providers.amazon.aws.example_dags.example_dms.ROLE_ARN[source]
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.RDS_DB_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_NAME[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.set_up()[source]
airflow.providers.amazon.aws.example_dags.example_dms.clean_up()[source]
airflow.providers.amazon.aws.example_dags.example_dms.create_task[source]

Was this entry helpful?