数据湖探索 DLI-DDS输出流:示例

时间：2024-07-01 21:07:18

数据湖探索 DLI 创建输出流

示例

将流qualified_cars 的数据输出到文档数据库collectionTest。

  
   
     
     
       CREATE SINK STREAM qualified_cars (
  car_id STRING,
  car_owner STRING,
  car_age INT,
  average_speed INT,
  total_miles INT
)
  WITH (
    type = "dds",
    region = "xxx",
    db_url = "192.168.0.8:8635,192.168.0.130:8635/dbtest/collectionTest",
    username = "xxxxxxxxxx",
    password =  "xxxxxxxxxx",
    field_names = "car_id,car_owner,car_age,average_speed,total_miles",
    batch_insert_data_num = "10"
  );

      

    

  
 