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