public createReplicationTask()

in lib/dms-replication.ts [136:168]

32 lines of code
2 McCabe index (conditional complexity)


  public createReplicationTask(
    replicationTaskIdentifier: string,
    schema: string,
    source: CfnEndpoint,
    target: CfnEndpoint,
    migrationType?: 'cdc' | 'full-load' | 'full-load-and-cdc',
    replicationTaskSettings?: TaskSettings
  ): CfnReplicationTask {
    const replicationTask = new CfnReplicationTask(this, replicationTaskIdentifier, {
      replicationInstanceArn: this.instance.ref,
      replicationTaskIdentifier: replicationTaskIdentifier,
      migrationType: migrationType || 'full-load',
      sourceEndpointArn: source.ref,
      targetEndpointArn: target.ref,
      replicationTaskSettings: JSON.stringify(replicationTaskSettings),
      tableMappings: JSON.stringify({
        rules: [
          {
            'rule-type': 'selection',
            'rule-id': '1',
            'rule-name': '1',
            'object-locator': {
              'schema-name': schema,
              'table-name': '%',
            },
            'rule-action': 'include',
          },
        ],
      }),
    });

    return replicationTask;
  }