Oracle英文版培训课件之Implement Streams：les08

ConfiguringaCaptureProcessObjectivesAftercompletingthislesson,youshouldbeabletodothefollowing:ConfigureacaptureprocessManageacaptureprocessMonitoracaptureprocessPrerequisitesBeforeyoucreateacaptureprocess,youmustcompletethefollowingsteps:ConfigurethedatabaseinitializationparametersEnablearchivelogging.CreateaStreamsqueuetoassociatewiththecaptureprocess,ifonedoesnotalreadyexist.AutomaticallycreatetheStreamsqueuesusingtheMaintainscripts.CreatingtheCaptureProcessAutomaticallycreateacaptureprocessbyusingDBMS_STREAMS_ADM:ADD_TABLE_RULESADD_SCHEMA_RULESADD_GLOBAL_RULESADD_SUBSET_RULESMAINTAIN_*proceduresManuallycreateacaptureprocessbycallingtheCREATE_CAPTUREprocedureofDBMS_CAPTURE_ADM.Creationofthefirstcaptureprocessinadatabasemaytaketimebecausethedatadictionaryisbeingcopiedtotheredologs.CreatingtheCaptureProcessDBMS_STREAMS_ADM.ADD_TABLE_RULES(table_nameINVARCHAR2,streams_typeINVARCHAR2,streams_nameINVARCHAR2DEFAULTNULL,queue_nameINVARCHAR2DEFAULT'streams_queue',include_dmlINBOOLEANDEFAULTtrue,include_ddlINBOOLEANDEFAULTfalse,include_tagged_lcrINBOOLEANDEFAULTfalse,source_databaseINVARCHAR2DEFAULTNULL,dml_rule_nameOUTVARCHAR2,ddl_rule_nameOUTVARCHAR2,inclusion_ruleINBOOLEANDEFAULTtrue,and_conditionINVARCHAR2DEFAULTNULL);CreatingtheCaptureProcessExampleofcreatingacaptureprocessautomatically:BEGINDBMS_STREAMS_ADM.ADD_TABLE_RULES(table_name=>'HR.LOCATIONS',streams_type=>'capture',streams_name=>'capture1',queue_name=>'streams_queue',include_dml=>TRUE,include_ddl=>FALSE,include_tagged_lcr=>FALSE,inclusion_rule=>TRUE);END;/ManuallyCreatingtheCaptureProcessExampleofcreatingacaptureprocessbyusingtheDBMS_CAPTURE_ADMpackage:BEGINDBMS_CAPTURE_ADM.CREATE_CAPTURE(queue_name=>'hr_queue',capture_name=>'hr_capture',rule_set_name=>'hr.hr_4_RS',negative_rule_set_name=>NULL,capture_user=>'STRMADMIN');END;/PrerequisitesforDownstreamCaptureConfigureStreamsadministratoruserandstagingqueue.Configurenetworkconnectivity.Optionally,createadatabaselinkfromthetargetbacktothesourcedatabase.Enablesupplementalloggingonsourcedatabaseifnotusingadatabaselink.Configurelogtransportservices.ALTERSYSTEMSETlog_archive_dest_2='SERVICE=SITE2.NETLGWRSYNCOPTIONALNOREGISTERVALID_FOR=(ONLINE_LOGFILE,PRIMARY_ROLE)'ConfiguringLogTransportServices

attheSourceDatabaseUseexistingdatabaseinitializationparameters:LOG_ARCHIVE_DEST_nSpecifyARCHforarchivedlogsUseLGWR

SYNCforreal-timeminingofredologsLOG_ARCHIVE_DEST_STATE_nLOG_ARCHIVE_FORMATREMOTE_ARCHIVE_ENABLElog_archive_dest_2='SERVICE=SITE2.NETARCH

MANDATORYNOREGISTERREOPEN=120

TEMPLATE=/oracle/arch/SITE2_%t_%s_%r.arc';log_archive_dest_2='SERVICE=SITE2.NETLGWRSYNCOPTIONAL

NOREGISTERVALID_FOR=(ONLINE_LOGFILE,PRIMARY_ROLE)'ConfiguringStandbyLogsatthe

DestinationDatabaseModifyatleastoneoftheLOG_ARCHIVE_DEST_ninitializationdatabaseparametersforthedownstreamdatabaseandspecifythefollowing:LOCATIONMANDATORYVALID_FORLOG_ARCHIVE_DEST_4='LOCATION=/home/arc_dest/sitelMANDATORYVALID_FOR=(STANDBY_LOGFILE,PRIMARY_ROLE)'CreatingaDownstreamCaptureProcesswithaDatabaseLinkLogtransportStaging

queueDatabaselinkCaptureRules11123Site1Site2CreatingaDownstreamCaptureProcess

WithoutaDatabaseLinkLogtransportStaging

queueRules1124Site1Site2SGASharedpoolDatadictionarycacheStreams

poolCapture3SettingCaptureProcessParametersUseDBMS_CAPTURE_ADMpackageto:AlterthecaptureprocessconfigurationSetcaptureprocessparametersthatcontrolthewayacaptureprocessoperatesBEGINDBMS_CAPTURE_ADM.SET_PARAMETER(capture_name=>'capture1',parameter=>'parallelism',value=>'1');END;/CaptureProcessParametersDISABLE_ON_LIMITDOWNSTREAM_REAL_TIME_MINEMAXIMUM_SCNMESSAGE_LIMITPARALLELISMSTARTUP_SECONDSTIME_LIMITTRACE_LEVELWRITE_ALERT_LOGStartingtheCaptureProcessWhenyoucreateacaptureprocess,itdoesnotstartautomatically.ThisallowstheDBAtosetthecaptureparametersappropriatelybeforecapturestarts.Youshouldnotstartcaptureuntilallapplyprocessesandpropagationjobshavebeenconfiguredandstarted.Tostartthecaptureprocess,usetheDBMS_CAPTURE_ADM.START_CAPTUREprocedure.EXECDBMS_CAPTURE_ADM.START_CAPTURE('capture1');ManagingCaptureProcessesTheDBMS_CAPTURE_ADMpackagehasthefollowingproceduresformanagingthecaptureprocess:CREATE_CAPTURESET_PARAMETERSTART_CAPTUREandSTOP_CAPTUREDROP_CAPTUREALTER_CAPTURE,whichisusedto:SpecifyorremoveapositiveornegativerulesetChangethestartSCNorfirstSCNAlterdownstreamcapturetouseadatabaselinkSpecifyacaptureuserChangethedurationforcheckpointinformationretentionManagingCaptureProcessesExample: AlteringtheHR_CAPTUREcaptureprocesstoremovetheHR_4_RSpositiverulesetandusetheEMPNEG_RSinsteadBEGINDBMS_CAPTURE_ADM.ALTER_CAPTURE(capture_name=>'hr_capture',remove_rule_set=>TRUE,negative_rule_set_name=>'HR.EMPNEG_RS');END;/MonitoringCaptureProcessesToviewinformationaboutthecaptureprocess:DBA_CAPTUREDBA_CAPTURE_PARAMETERSDBA_CAPTURE_EXTRA_ATTRIBUTESV$STREAMS_CAPTUREV$STREAMS_TRANSACTIONDBA_STREAMS_RULESToviewinformationaboutthearchivedredologsthatareusedbythecaptureprocess:DBA_REGISTERED_ARCHIVED_LOGDBA_LOGMNR_PURGED_LOGMonitoringDownstreamCaptureProcessesSELECTcapture_name,queue_name,status,

source_database,capture_typeFROMDBA_CAPTURE;CAPTURE_NAMEQUEUE_NAME---------------------------------------------STATUSSOURCE_DATABASECAPTURE_TYPE--------------------------------------------CAPTURE_DOWNSTREAM_SITE1STREAMS_QUEUEDISABLEDSITE1.NETDOWNSTREAMMonitoringLogFileAvailabilitySELECTr.CONSUMER_NAME,r.SOURCE_DATABASESRC_DB,

r.SEQUENCE#,r.NAME,

r.DICTIONARY_BEGINBEGIN,

r.DICTIONARY_ENDEND

FROMDBA_REGISTERED_ARCHIVED_LOGr,DBA_CAPTUREc

WHEREr.CONSUMER_NAME=c.CAPTURE_NAME;

CONSUMER_NAMESRC_DBSEQUENCE#-------------------------------------------------NAMEBEGINEND-----------------------------------------------CAPTURE_DOWNSTREAM_SITE1SITE1.NET95/oracle/arch/SITE1_1_95_483970920.arcYESYESCAPTURE_DOWNSTREAM_SITE1SITE1.NET96/oracle/arch/SITE1_1_96_483970920.arcNONOCapture-ProcessStatisticsV$STREAMS_CAPTUREdisplaysinformationaboutthecaptureprocesses:StateofthecaptureprocessTotalnumberofeventsthatarecapturedTotalnumberofeventsthatareenqueuedCreationtimeofthemostrecenteventCreationtimeofthelast-enqueuedeventTimespentcapturingchangesTimespentevaluatingrulesTimespentenqueuingeventsTimespentcreatingLCRsEm_capture_stats_2_my.gifEm_capture_stats_1_my.gifCapture-ProcessStatistics

inOracleEnterpriseManagerTroubleshootingCaptureCheckthecaptureprocessstatus.Checktherulesandruleconditionsthatareusedbythecaptureprocess.Checkforerrors.CaptureProcess:StatusCheckthestateofthecaptureprocess:Enabled?Isthecaptureprocesscurrent?Abortedordisabled?Checkforerrors.SELECTcapture_name,queue_name,status,

error_number,error_messageFROMDBA_CAPTURE;SELECTcapture_name,state,

total_messages_captured,total_messages_enqueued,enqueue_message_create_timeFROMV$STREAMS_CAPTURE;ChecktheCaptureProcessRulesCheckDBA_STREAMS_RULESorasimilarview.Queryfornegativerulesets.Checkforemptyrulesets.Determineifthesystem-createdruleconditionhasbeenmodifiedwithDBMS_RULE_ADM.SELECTstreams_name,rule_owner,rule_name,

rule_condition,rule_set_typeTYPE,

streams_rule_typeLEVEL,

schema_name,object_name,subsetting_operation,

dml_condition,same_rule_condition"Orig?"FROMdba_streams_rulesWHEREstreams_type='CAPTURE';ORA-00902:invaliddatatypeORA-00902:invaliddatatypeThecaptureprocessisaborted.TracefileshowsORA-00902.Reviewrulestoverifythatrulesaredefinedonlyontableswithcolumns