docs-archive/apache-airflow-providers-amazon/2.0.0/_sources/_api/airflow/providers/amazon/aws/operators/dms_create_task/index.rst.txt

:mod:`airflow.providers.amazon.aws.operators.dms_create_task`
=============================================================

.. py:module:: airflow.providers.amazon.aws.operators.dms_create_task


Module Contents
---------------

.. py:class:: DmsCreateTaskOperator(*, replication_task_id: str, source_endpoint_arn: str, target_endpoint_arn: str, replication_instance_arn: str, table_mappings: dict, migration_type: Optional[str] = 'full-load', create_task_kwargs: Optional[dict] = None, aws_conn_id: str = 'aws_default', **kwargs)

   Bases: :class:`airflow.models.BaseOperator`

   Creates AWS DMS replication task.

   .. seealso::
       For more information on how to use this operator, take a look at the guide:
       :ref:`howto/operator:DmsCreateTaskOperator`

   :param replication_task_id: Replication task id
   :type replication_task_id: str
   :param source_endpoint_arn: Source endpoint ARN
   :type source_endpoint_arn: str
   :param target_endpoint_arn: Target endpoint ARN
   :type target_endpoint_arn: str
   :param replication_instance_arn: Replication instance ARN
   :type replication_instance_arn: str
   :param table_mappings: Table mappings
   :type table_mappings: dict
   :param migration_type: Migration type ('full-load'|'cdc'|'full-load-and-cdc'), full-load by default.
   :type migration_type: str
   :param create_task_kwargs: Extra arguments for DMS replication task creation.
   :type create_task_kwargs: Optional[dict]
   :param aws_conn_id: The Airflow connection used for AWS credentials.
       If this is None or empty then the default boto3 behaviour is used. If
       running Airflow in a distributed manner and aws_conn_id is None or
       empty, then default boto3 configuration would be used (and must be
       maintained on each worker node).
   :type aws_conn_id: Optional[str]

   .. attribute:: template_fields
      :annotation: = ['replication_task_id', 'source_endpoint_arn', 'target_endpoint_arn', 'replication_instance_arn', 'table_mappings', 'migration_type', 'create_task_kwargs']

      

   .. attribute:: template_ext
      :annotation: = []

      

   .. attribute:: template_fields_renderers
      

      

   
   .. method:: execute(self, context)

      Creates AWS DMS replication task from Airflow

      :return: replication task arn