本文为您介绍如何配置MongoDB输入组件。

操作步骤

  1. 请参见通过离线单条管道配置集成任务,进入单条管道脚本的开发页面。
  2. 按照下图指引,进入MongoDB输入配置对话框。
    z
  3. MongoDB输入配置对话框,配置参数。
    z
    参数说明
    步骤名称根据当前组件的使用场景,填写名称。
    数据源选择数据源。选取Dataphin系统中已配置的数据源,且数据源需同时具备以下两个条件:
    • 数据源类型为MongoDB。
    • 执行属性配置的账号具有该数据源的同步读权限,如果没有权限,则需要申请数据源权限,详情请参见管理数据源权限
    同时您可以单击数据源后的新建,进入规划模块添加数据源,详情请参见创建MongoDB数据源
    选择来源表。
    输入过滤填写输入字段的过滤信息,例如ds=${bizdate}输入过滤适用于以下两种场景:
    • 固定的某一部分数据。
    • 参数过滤。
    输出字段为您展示输出字段。 您可以执行以下操作手动添加输出字段:
    • 单击批量添加 ,以JSON格式批量配置,完成配置后单击确认,示例如下。
      
      [{  "name":"cf1:a",  "type":"String" },
      {  "name":"cf1:b",  "type":"String" }]
    • 单击新建输出字段,根据页面提示填写字段及选择字段的类型
    同时您也可以对已添加的字段执行如下操作:
    • 单击操作列下的agag图标,编辑已有的字段。
    • 单击>操作列下的agfag图标,删除已有的字段。
  4. 单击确认,完成MongoDB输入组件的属性配置。

后续步骤

完成输入组件的配置后,即可配置下游组件,以实现数据同步。具体操作,请参见通过离线单条管道配置集成任务