replication

Module to interact with replications.

This module contains class to interact with a replication in EMS data integration.

Typical usage example:

replication = data_connection.get_replication(
    "ID"
)

replication.initialize(
    extraction=True,
    transformation=True,
)
replication.start()
replication.stop()
replication.delete()

Replication

Bases: ReplicationTransport

Replication object to interact with replication specific data integration endpoints.

cl_override_enabled class-attribute instance-attribute

cl_override_enabled = Field(alias='clOverrideEnabled')

cl_override_table_name class-attribute instance-attribute

cl_override_table_name = Field(alias='clOverrideTableName')

connector_specific_configuration class-attribute instance-attribute

connector_specific_configuration = Field(
    alias="connectorSpecificConfiguration"
)

custom_target_table_name class-attribute instance-attribute

custom_target_table_name = Field(
    alias="customTargetTableName"
)

data_push_delete_strategy class-attribute instance-attribute

data_push_delete_strategy = Field(
    alias="dataPushDeleteStrategy"
)

data_source_id class-attribute instance-attribute

data_source_id = Field(alias='dataSourceId')

debug_mode_until class-attribute instance-attribute

debug_mode_until = Field(alias='debugModeUntil')

filter_statement class-attribute instance-attribute

filter_statement = Field(alias='filterStatement')

latest_status_change class-attribute instance-attribute

latest_status_change = Field(alias='latestStatusChange')

metadata_delta_filter_id class-attribute instance-attribute

metadata_delta_filter_id = Field(
    alias="metadataDeltaFilterId"
)

rename_target_table class-attribute instance-attribute

rename_target_table = Field(alias='renameTargetTable')

schema_name class-attribute instance-attribute

schema_name = Field(alias='schemaName')

status class-attribute instance-attribute

status = Field(alias='status')

type_ class-attribute instance-attribute

type_ = Field(alias='type')

client class-attribute instance-attribute

client = Field(..., exclude=True)

id instance-attribute

id

Id of replication.

data_pool_id instance-attribute

data_pool_id

Id of data pool where replication is located.

table_name instance-attribute

table_name

Name of table.

from_transport classmethod

from_transport(client, replication_transport)

Creates high-level replication object from the given ReplicationTransport.

Parameters:

• client (Client) –

  Client to use to make API calls for given job.

• replication_transport (ReplicationTransport) –

  ReplicationTransport object containing properties of replication.

Returns:

• Replication –

  A Replication object with properties from transport and given client.

sync

sync()

Syncs replication properties with EMS.

delete

delete()

Deletes replication.

initialize

initialize(
    extraction=True,
    transformation=True,
    initialization_script_ids=None,
)

Initializes replication which triggers complete reload of data.

Parameters:

• extraction (bool, default: True ) –

  Whether to select extraction for initialization.

• transformation (bool, default: True ) –

  Whether to select transformation for initialization.

• initialization_script_ids (Optional[List[str]], default: None ) –

  Optional list of initialization script ids to use for initialization.

start

start()

Starts replication.

stop

stop()

Stops replication.