Skip to content

MongoDB source 用于支持 DataFlow 从 MongoDB 数据库中加载 Dataset。MongoDB的数据结构为Document,可理解为一个JSON。其中_id为 Document 的主键。

xml
<source type="mongodb"
        table_name="cust_id_agmt_id_t"
        columns_mapping="name1,cust_id,name,gender1,age1,age"
        mongodb_uri="mongodb://localhost:27017/test_db.hello"
/>

配置说明:

  1. columns_mapping 为指定列映射,_id 为mongodb的主键,如果没有_id列,则采用第一列为_id(如实例中,name1 为 MongoDB中的 _id列); 其他列为mongodb doc中的列;columns_mapping指定列的同时,也可指定列的类型,切分逻辑为 Field:type ;
  2. mongodb_uri: 完整的MongoDBURI 地址,一般格式为:mongodb://[username:password@]host:port/dbname.collection_name;