blob: 78e4e0c41f032b07d02dc3f7e718ee8943ec5f88 [file] [log] [blame]
: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