【数据同步】SeaTunnel初体验，5000字深入浅出带你用上Oracle-CDC

在这个问题中，我们需要创建一个SeaTunnel同步Oracle数据库变更日志的作业。以下是一个简化的解决方案：

// 引入必要的SeaTunnel模块
set sync.provider.parameter.oracle.cdc.jars=`ls /path/to/seatunnel/oracle-cdc-connector.jar`
 
// 定义数据源
CREATE SOURCE oracle_source_cdc_binlog_demo
`debezium-json`(
  `connector.class`="io.debezium.connector.oracle.OracleConnector",
  `snapshot.mode`="initial",
  `database.hostname`="your_oracle_host",
  `database.port`="1521",
  `database.user`="your_oracle_user",
  `database.password`="your_oracle_password",
  `database.dbname`="your_oracle_service_name",
  `database.server.name`="oracle_cdc_server",
  `database.history.kafka.bootstrap.servers`="your_kafka_server",
  `database.history.kafka.topic`="oracle_history_topic",
  `include.schema.changes`="true",
  `snapshot.locking.mode`="none"
)
 
// 定义数据目的地
CREATE SINK hdfs_sink_demo
`hdfs`(
  `path`="/path/to/hdfs/data",
  `filePrefix`="oracle-data",
  `fileType`="orc",
  `fileName`="`filePrefix`-`dateFormat(yyyyMMdd, eventTimestamp)`"
)
 
// 定义同步任务
CREATE JOB oracle_cdc_to_hdfs_job
`seatunnel`(
  `pre.commands`="set log.level='ERROR'",
  `streaming`="true",
  `interval`="1",
  `mode`="incremental",
  `source`="oracle_source_cdc_binlog_demo",
  `sink`="hdfs_sink_demo"
)

在这个简化的例子中，我们定义了一个数据源来使用Debezium进行Oracle数据库的变更数据捕获，并定义了一个数据目的地将数据写入HDFS。最后，我们创建了一个同步作业来周期性地执行这个数据同步任务。这个例子展示了如何使用SeaTunnel进行实时数据同步，并且是一个很好的入门级示例。