[实时盘算flink]数据摄入YAML作业快速入门

实时盘算Flink版基于Flink CDC，通过开辟YAML作业的方式有用地实现了将数据从源端同步到目的端的数据摄入工作。本文先容怎样快速构建一个YAML作业将MySQL库中的全部数据同步到StarRocks中。
条件条件

  

• 已创建Flink工作空间，详情请拜见开通实时盘算Flink版。
    
  
• 上鄙俚存储
     
  
     
  
  • 已创建RDS MySQL实例，详情请拜见快速创建RDS MySQL实例。
       
    
  • 已创建StarRocks实例，详情请拜见步调一：创建存算一体版StarRocks实例。
       
    
  分析
  RDS MySQL和StarRocks须要与Flink工作空间在雷同VPC下，否则须要买通网络和设置RDS MySQL的IP白名单，详情请拜见怎样访问跨VPC的其他服务？、实时盘算Flink版怎样访问公网？和操纵引导。
  
  

配景信息

假设MySQL实例中有一个order_dw_mysql库，内里闻名称为orders、orders_pay和product_catalog的3张业务表。此时，假如您盼望开辟一个数据摄入YAML作业，将这些表和数据都同步到StarRocks的order_dw_sr数据库中，则可以按照以下步调举行：

  

• 步调一：预备RDS MySQL测试数据
    
  
• 步调二：开辟数据摄入YAML作业
    
  
• 步调三：启动数据摄入YAML作业
    
  
• 步调四：在StarRocks上查察同步结果
  
  

步调一：预备RDS MySQL测试数据

  

• 创建数据库和账号。
  为目的实例创建名称为order_dw_mysql数据库和具有对应数据库读写权限的平常账号。详细操纵请拜见