Create a ggadmin user using the following script. Remember to
replace <ggadmin-password> with a valid password:
CREATE USER 'ggadmin' IDENTIFIED BY '<ggadmin-password>';
GRANT SELECT, REPLICATION SLAVE, REPLICATION CLIENT, CREATE,CREATE VIEW, EVENT, INSERT, UPDATE, DROP,EXECUTE, DELETE ON *.* TO 'ggadmin';
Open port 3306, through which OCI GoldenGate can
connect.
In the Oracle Cloud console, locate the subnet that the HeatWave database uses.
In the security list of the subnet, create an Ingress rule for
port TCP/3306.
Parameter File: Replace MAP *.*, TARGET
*.*; with TABLE SRC_OCIGGLL.*;
Task 3: Create the Distribution Path to target Big Data deployment
🔗
If using IAM credential store, proceed Step 3. If using GoldenGate credential
store, create a user with which the source GoldenGate uses to connect to the
target GoldenGate.
On the Deployments page, select the target Big Data
deployment.
On the deployment details page, click Launch Console, and then
log in as the admin user.
In the deployment console navigation menu, click User
Administration.
Click Add New User (plus icon), complete the fields as follows,
and then click Submit:
For Username, enter
ggsnet.
For Role, select
Operator.
Enter the password twice for verification.
In the source MySQL deployment console, create a Path
Connection for the user created in the previous step.
Open the navigation menu, and then click Path
Connection.
Click Add Path Connection (plus icon),
complete the fields as follows, and then click Submit:
For Credential Alias, enter
dpuser.
For User ID, enter ggsnet
For Password, enter the same password used in
the previous step.
For Target Trail Name, enter the name of the Trail
from Task 2.
For Target, select Amazon Kinesis.
For Available Aliases for Amazon Kinesis, select your alias from the
dropdown.
On the Properties File page, edit the fields marked
#TODO:
gg.handler.kinesis.region: provide the Amazon
Web Services (AWS) region for the target Kinesis stream.
gg.handler.kinesis.streamMappingTemplate: by
default, it is set to ${tableName} which will
map the streams based on source table name. If you want to map
to an existing data stream, you can provide static stream names
or you can use Template
Keywords to assign stream names dynamically.
Task 5: Verify Data
Replication from HeatWave to Amazon Kinesis 🔗
Perform updates to the source HeatWave database to
verify replication to Amazon Kinesis.
In OCI Bastion, create an SSH port forwarding session using MySQL IP and
port 3306. Add your public SSH key.
Connect to MySQL in Cloud Shell using your private key and port
3306.
After connecting successfully, run the following command:
mysqlsh admin@localhost:3306 --sql
Run the following script to perform inserts into the HeatWave
database:
use SRC_OCIGGLL;
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1000,'Houston',20,743113);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1001,'Dallas',20,822416);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1002,'San Francisco',21,157574);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1003,'Los Angeles',21,743878);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1004,'San Diego',21,840689);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1005,'Chicago',23,616472);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1006,'Memphis',23,580075);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1007,'New York City',22,124434);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1008,'Boston',22,275581);
Insert into SRC_OCIGGLL.SRC_CITY (CITY_ID,CITY,REGION_ID,POPULATION) values (1009,'Washington D.C.',22,688002);
commit;
In the source MySQL deployment console, select the Change
Data Capture Extract name (CDCEXT), and then click
Statistics. Verify that SRC_OCIGGLL.SRC_CITY has 10
inserts.
In target Big Data deployment console, select the Replicat Name and then click Statistics. Verify that
SRC_OCIGGLL.SRC_CITY has 10 inserts.
In Amazon Kinesis, you can check the messages in target data
stream/data viewer.