7/29/2019 How to Setup Streams

1/5

How to Setup the Streams Environments

Setup devbhist Destination Streams for Activity:

This section setup devbhist database to APPLY both billable and non-billable activityrecords that were inserted into the activity table on the DEVACT database. Thetransaction volume is estimated to around 1 million records per day. The scripts to setupthis environment are located on anadev20 in directory/dba/scripts/INFOCUS/9i/devbhist .

Create the Apply User activity and activity_apps.

Create the Streams Administrator, Streams Queue, Table Rules, specify the

Apply User and prevent the APPLY process from terminating on every error.

SQL> @cr_dest_streams_admin.sql

Create the activity table

SQL> cr_activity.sql

Start the APPLY process on devbhist database.

SQL> @start_apply_destination.sql

Setup INFDEV Destination Streams for Activity:

For database infdev, only the billable activity records are Streamed. The steps to setupthe Streams APPLY process is similar to the procedures above for database devbhist.Scripts are found on server anadev30 in directory /dba/scripts/INFOCUS/9i/infdev .

Create the Apply User activity.

Create the Streams Administrator, Streams Queue, Table Rules, specify the

Apply User and prevent the APPLY process from terminating on every error.

SQL> @cr_dest_streams_admin.sql

Create the activity table

SQL> @cr_activity.sql

1

7/29/2019 How to Setup Streams

2/5

Start the APPLY process on infdev database.

SQL> @start_apply_destination.sql

Setup DEVBHIST Destination Streams for User_Profile:

This section will setup the devbhist database to APPLY the user_profile records thatwere massaged in the Passport database. The User Profile transaction will be low volume.The scripts are located on anadev20 in directory /dba/scripts/INFOCUS/9i/devbhist .

Create the apply User passport and passport_apps.

Setup the Passport Queue, passport table rules, specify the Apply User

(passport) and prevent the Apply Process from terminating upon every error.

SQL> @cr_streams_pst_2_bhist_q.sql

Create the User Profile table

SQL> @cr_user_profile.sql

Start the second APPLY process on devbhist database.

SQL> @start_apply_pst.sql

Setup DEVACT Source Streams for Activity:

This section show how to setup source Streams environment which will create theCapture and Propagate processes on DEVACT database. The scripts are located on serveranadev30 in directory /dba/scripts/INFOCUS/10g/devact .

Create schema activity and activity_apps.

Create Activity tables:

SQL> @cr_activity.sqlSQL> @cr_heart_beat_tbl.sqlSQL> @create_host.sqlSQL> @create_activity_id_seq.sql

SQL> @setup_src_streams.sql

SQL> @set_instantiation_scn.sql

2

7/29/2019 How to Setup Streams

3/5

Start the CAPTURE process:

SQL> @start_src_capture.sqlSetup DEVPST Source Streams for User_Profile:

This section show how to setup the CAPTURE and PROPAGATION processes on the

DEVPST database. The script(s) are located on server anadev30 in directory/dba/scripts/INFOCUS/10g/devpst .

Create schemas passport,passport_apps and strmadmin

Create strmadmin types and Message Types:

SQL> @cr_passport_db_types.sqlSQL> @fam_message_structures_ddl.sql

Compile passport package:

SQL> conn passport/.SQL> @FAM_PROV_ENCRYPT_PUB_wrap01252006.plb

Create table User_Profile:

SQL> @cr_passport_9.sql

Create the Streams environment:

SQL> @setup_passport_strmadmin.sql

Instantiate Table SCN to destination database

SQL> @set_user_profile_table_instant.sql

Start the CAPTURE process:

SQL> @start_src_pst_capture.sql

3

7/29/2019 How to Setup Streams

4/5

Setup Advanced Queue on DEVPST database:

This section demonstrate how to setup Advanced Queuing on DEVPST database. Thescripts are located on server anadev30 in directory/dba/scripts/INFOCUS/10g/devpst .

Create Advanced Queue Queues on DEVPST database:

SQL> @create_aq_queues.sqlSQL> @grant_queue_privs.sql

Obtain source Packages, Functions, Procedures from developers and compile

each.

NOTE: Ask Vasan V., Randy G., Michael Mount, August Harrison

Start the batch script to dequeue messages every few seconds in the background.

$ nohup manually_dequeue_msg.sh > dequeue.log &

Created by Administrator: Larry BaileyCreated on: 08/18/2006

4

7/29/2019 How to Setup Streams

5/5

5