普元数据开发平台
产品介绍
安装部署
FAQ

# MongoDB输入组件使用说明

# 基础说明

MongDB输入组件用于从MongoDB的集合中检索文档或记录。

# 配置清单

配置名称 数据类型 是否必须 默认值 描述
节点名称 String 是 - 当前创建的节点名称，由用户自定义且不可为空。命名可包含字母、数字、下划线。
选择数据源 String 是 - 当前输入绑定的数据源名称，从下拉选项中列出的指定的关联类型(MongoDB)的数据源进行选择。
库名称 String 是 - 指定要从中检索信息的数据库。
集合 String 是 - 指定要从中检索信息的集合。
标签集 String 是 - 标记允许您自定义副本集的写关注点和读首选项。可以通过“测试标签集”来查看哪些标签集匹配规范标准，将显示每个匹配标签集规格条件的标签集成员的ID、主机名、优先级和标签。
查询 String 是 - 在此字段中输入查询表达式以限制输出。
查询模式 String 是 - 选择“JSON查询”来显示JSON字段，而后字段表达式使用MongoDB的类似json的查询语言和查询操作符来执行查询操作。选择“聚合查询” 使用MongoDB的聚合框架来转换和组合集合中的文档。聚合管道连接多个管道表达式,与前面的表达式的输出成为下一个的输入。
字段表达式 String 是 - 输入一个参数来控制查询的投影(要返回的字段)。如果为空，则返回所有字段。此字段仅对查询表达式可用。
使用磁盘缓存 Boolean 是 false 选择此选项可打开allowDiskUse属性，以便在聚合管道数据超过标准的100MB RAM分配时处理聚合管道数据。
逐行执行 Boolean 是 false 选择此选项对每一行数据执行查询。
读取策略 String 是 primary 指定首先读取哪个节点:主节点、主首选节点、辅助节点、辅助首选节点或最近节点。
请求链接超时时间 Integer 是 30000 指定在终止连接尝试之前等待数据库连接的时间（以毫秒为单位）。
套接字超时 Integer 是 3600 指定在终止写入操作之前等待该操作的时间（以毫秒为单位）。
是否将结果输出到单个字段 String 是 - 指定查询结果为String数据类型(默认值)的单个JSON字段。
JSON输出字段的名称 String 是 - 指定包含来自服务器的JSON输出的字段名。
获取字段 - 是 - 点击“获取字段”以生成一组示例数据。您可以编辑示例中每个字段的字段名称、路径和数据类型列表。

# FAQ

Q: 当使用的mongoDB需要认证时，DI Server运行模型需要怎么配置？

A: 不同的认证方式，需要的配置项不同，具体如下：

  • 使用用户名密码方式认证时，DI Server无需额外配置，直接运行模型即可；

  • 使用SSL认证方式时，需要在${DI_HOME}/diserver/ssl/{datasourceCode}/{envType}/目录下放置ca.pem、client.pem认证文件

    注意：
DI_HOME 即Primeton DI安装目录
datasourceCode为模型中使用DWS系统中的mongoDB数据源编码
envType为环境类型，如dev、test、pro
ssl及下层目录不存在时，可手动创建
文件夹层级格式不可修改，每层都必须有

    image-20250224155941931

  • 使用kerberos 认证方式时，需要做如下配置：

    1. 需要在${DI_HOME}/diserver/kerberos目录下放置krb5.conf、krb5.keytab、config.properties

    krb5.conf和krb5.keytab文件从mongoDB服务器获取

    1. config.properties中配置username.client.kerberos.principal=your_principal@MONGO.COM

DI配置以上参数后，需要重启生效。

← SAP输入 →