|
| 1 | +--- |
| 2 | +Title: Define data pipeline |
| 3 | +alwaysopen: false |
| 4 | +categories: |
| 5 | +- docs |
| 6 | +- operate |
| 7 | +- rc |
| 8 | +description: Define the source connection and data pipeline. |
| 9 | +hideListLinks: true |
| 10 | +weight: 2 |
| 11 | +--- |
| 12 | + |
| 13 | +After you have [prepared your source database]({{<relref "/operate/rc/databases/rdi/setup">}}) and connection information, you can set up your new pipeline. To do this: |
| 14 | + |
| 15 | +1. [Define the source connection](#define-source-connection) by entering all required source database information. |
| 16 | +2. [Define the data pipeline](#define-data-pipeline) by selecting the data that you want to sync from your source database to the target database. |
| 17 | + |
| 18 | +## Define source connection |
| 19 | + |
| 20 | +1. In the [Redis Cloud console](https://cloud.redis.io/), go to your target database and select the **Data Pipeline** tab. |
| 21 | +1. Select **Define source database**. |
| 22 | + {{<image filename="images/rc/rdi/rdi-define-source-database.png" alt="The define source database button." width=200px >}} |
| 23 | +1. Enter a **Pipeline name**. |
| 24 | + {{<image filename="images/rc/rdi/rdi-define-pipeline-cidr.png" alt="The pipeline name and deployment CIDR fields." >}} |
| 25 | +1. A **Deployment CIDR** is automatically generated for you. If, for any reason, a CIDR is not generated, enter a valid CIDR that does not conflict with your applications or other databases. |
| 26 | +1. In the **Source database connectivity** section, enter the **PrivateLink service name** of the [PrivateLink connected to your source database]({{< relref "/operate/rc/databases/rdi/setup#set-up-connectivity" >}}). |
| 27 | + {{<image filename="images/rc/rdi/rdi-define-connectivity.png" alt="The Source database connectivity section, with database connection details and connectivity options." >}} |
| 28 | +1. Enter your database details. This depends on your database type, and includes: |
| 29 | + - **Port**: The database's port |
| 30 | + - **Database**: Your database's name, or the root database *(PostgreSQL, Oracle only)*, or a comma-separated list of one or more databases you want to connect to *(SQL Server only)* |
| 31 | + - **Database Server ID**: Unique ID for the replication client. Enter a number that is not used by any existing replication clients *(mySQL and mariaDB only)* |
| 32 | + - **PDB**: Name of the Oracle pluggable database *(Oracle only)* |
| 33 | +1. Enter the ARN of your [database credentials secret]({{< relref "/operate/rc/databases/rdi/setup#create-database-credentials-secrets" >}}) in the **Source database secrets ARN** field. |
| 34 | +1. If your database requires TLS, select **Use TLS**. Enter the ARN of your [CA certificate secret]({{< relref "/operate/rc/databases/rdi/setup#create-database-credentials-secrets" >}}) in the **CA Cert Secret ARN** field. |
| 35 | + {{<image filename="images/rc/rdi/rdi-define-tls.png" alt="The Source database connectivity section, with Use TLS selected and the CA Cert Secret ARN field." >}} |
| 36 | +1. If your database requires mTLS, select **Use mTLS**. Enter the ARN of your [Client certificate secret]({{< relref "/operate/rc/databases/rdi/setup#create-database-credentials-secrets" >}}) in the **Client Certificate Secret ARN** field and the ARN of your [Client key secret]({{< relref "/operate/rc/databases/rdi/setup#create-database-credentials-secrets" >}}) in the **Client Key Secret ARN** field. |
| 37 | + {{<image filename="images/rc/rdi/rdi-define-mtls.png" alt="The Source database connectivity section, with Use TLS selected and the Client Certificate Secret ARN and Client Key Secret ARN fields." >}} |
| 38 | +1. If your database requires mTLS with a client key passphrase, enter the ARN of your [Client key passphrase secret]({{< relref "/operate/rc/databases/rdi/setup#create-database-credentials-secrets" >}}) in the **Please add a secret ARN for the password to use with the secret store** field. |
| 39 | +1. Select **Start pipeline setup**. |
| 40 | + {{<image filename="images/rc/rdi/rdi-start-pipeline-setup.png" alt="The start pipeline setup button." width=200px >}} |
| 41 | +1. Redis Cloud will attempt to connect to PrivateLink. If your PrivateLink does not allow automatic acceptance of incoming connections, accept the incoming connection on AWS PrivateLink to proceed. See [Accept or Reject PrivateLink connection requests](https://docs.aws.amazon.com/vpc/latest/privatelink/configure-endpoint-service.html#accept-reject-connection-requests). |
| 42 | + |
| 43 | + If Redis Cloud can't find your PrivateLink connection, make sure that the PrivateLink service name is correct and that Redis Cloud is listed as an Allowed Principal for your VPC. See [Set up connectivity]({{<relref "/operate/rc/databases/rdi/setup#set-up-connectivity">}}) for more info. |
| 44 | + |
| 45 | +At this point, Redis Cloud will provision the pipeline infrastructure that will allow you to define your data pipeline. |
| 46 | + |
| 47 | +{{<image filename="images/rc/rdi/rdi-pipeline-setup-in-progress.png" alt="The Pipeline setup in progress screen." width=75% >}} |
| 48 | + |
| 49 | +Pipelines are provisioned in the background. You aren't allowed to make changes to your data pipeline or to your database during provisioning. This process will take about an hour, so you can close the window and come back later. |
| 50 | + |
| 51 | +When your pipeline is provisioned, select **Complete setup**. You will then [define your data pipeline](#define-data-pipeline). |
| 52 | + |
| 53 | +{{<image filename="images/rc/rdi/rdi-complete-setup.png" alt="The complete setup button." width=200px >}} |
| 54 | + |
| 55 | +## Define data pipeline |
| 56 | + |
| 57 | +After your pipeline is provisioned, you will be able to define your pipeline. You will select the database schemas, tables, and columns that you want to import and synchronize with your primary database. |
| 58 | + |
| 59 | +### Configure a new pipeline |
| 60 | + |
| 61 | +1. In the [Redis Cloud console](https://cloud.redis.io/), go to your target database and select the **Data Pipeline** tab. If your pipeline is already provisioned, select **Complete setup** to go to the **Data modeling** section. |
| 62 | + {{<image filename="images/rc/rdi/rdi-complete-setup.png" alt="The complete setup button." width=200px >}} |
| 63 | +1. Select the Schema and Tables you want to migrate to the target database from the list. |
| 64 | + {{<image filename="images/rc/rdi/rdi-select-source-data.png" alt="The data modeling section. " width=75% >}} |
| 65 | + |
| 66 | + Select **Manage Columns** to choose which columns you want to import. |
| 67 | + |
| 68 | + {{<image filename="images/rc/rdi/rdi-manage-columns.png" alt="The manage columns button." width=150px >}} |
| 69 | + |
| 70 | + You can select any number of columns from a table. |
| 71 | + |
| 72 | + {{<image filename="images/rc/rdi/rdi-select-columns.png" alt="The manage columns screen, with a few columns selected from one table" width=75% >}} |
| 73 | + |
| 74 | + If any tables are missing a unique constraint, a warning will appear in the **Data modeling** section. Select **Manage columns** to select the columns that define a unique constraint for those tables. |
| 75 | + |
| 76 | + {{<image filename="images/rc/rdi/rdi-missing-unique-constraint.png" alt="The missing unique constraint list." width=75% >}} |
| 77 | + |
| 78 | + {{<image filename="images/rc/rdi/rdi-select-constraints.png" alt="The missing unique constraint list with columns selected." width=75% >}} |
| 79 | + |
| 80 | + Select **Save** to save your column changes and go back to schema selection. |
| 81 | + |
| 82 | + {{<image filename="images/rc/button-save.png" alt="The save button." width=100px >}} |
| 83 | + |
| 84 | + Select **Add schema** to add more database schemas. |
| 85 | + |
| 86 | + {{<image filename="images/rc/rdi/rdi-add-schema.png" alt="The add schema button." width=150px >}} |
| 87 | + |
| 88 | + Select **Delete** to delete a schema. You must have at least one schema to continue. |
| 89 | + |
| 90 | + {{<image filename="images/rc/rdi/rdi-delete-schema.png" alt="The delete schema button." width=50px >}} |
| 91 | + |
| 92 | + After you've selected the schemas and tables you want to sync, select **Continue**. |
| 93 | + |
| 94 | + {{<image filename="images/rc/rdi/rdi-continue-button.png" alt="The continue button." width=150px >}} |
| 95 | + |
| 96 | +1. Select the Redis data type to write keys to the target. You can choose **Hash** or **JSON** if the target database supports JSON. |
| 97 | + {{<image filename="images/rc/rdi/rdi-configure-new-pipeline.png" alt="The pipeline definition screen." width=75% >}} |
| 98 | + |
| 99 | + You can also supply one or more [transformation job files]({{< relref "/integrate/redis-data-integration/data-pipelines/transform-examples" >}}) that specify how you want to transform the captured data before writing it to the target. Select **Upload jobs** to upload your job files. |
| 100 | + |
| 101 | + {{<image filename="images/rc/rdi/rdi-transformation-jobs.png" alt="The transformation jobs section. Select Upload jobs to upload transformation jobs." >}} |
| 102 | + |
| 103 | + When you upload job files, Redis Cloud will validate the job files to check for errors. |
| 104 | + |
| 105 | + Select **Continue**. |
| 106 | + {{<image filename="images/rc/rdi/rdi-continue-button.png" alt="The continue button." width=150px >}} |
| 107 | + |
| 108 | +1. Review the tables you selected in the **Review and deploy** section. If everything looks correct, select **Confirm & Deploy** to start ingesting data from your source database. |
| 109 | + |
| 110 | + {{<image filename="images/rc/rdi/rdi-confirm-deploy.png" alt="The Confirm & Deploy button." width=175px >}} |
| 111 | + |
| 112 | +At this point, the data pipeline will ingest data from the source database to your target Redis database. This process will take time, especially if you have a lot of records in your source database. |
| 113 | + |
| 114 | +After this initial sync is complete, the data pipeline enters the *change streaming* phase, where changes are captured as they happen. Changes in the source database are added to the target within a few seconds of capture. |
| 115 | + |
| 116 | +You can view the status of your data pipeline in the **Data pipeline** tab of your database. See [View and edit data pipeline]({{<relref "/operate/rc/databases/rdi/view-edit">}}) to learn more. |
0 commit comments