DB-doris

更新时间：2026-07-03

DB-Doris支持离线批量写入（Doris-batch）和实时流式写入（Doris-streaming）两类 sink 插件，适用于写入Databuilder平台内的Doris表进行 OLAP 分析查询。本文以 MySQL 作为源端示例。

Doris 插件类型

插件	plugin_name	_db_pluginId	作业类型	说明
Doris 离线写入	`Doris`	`Doris-batch`	`batch`	离线批量写入 Doris 表，适用于离线同步后的 OLAP 查询
Doris 流式写入	`Doris`	`Doris-streaming`	`streaming`	准实时 CDC 变更数据写入 Doris 表，支持 INSERT/UPDATE/DELETE 事件处理

脚本 Demo 与参数说明

一、离线任务：MySQL → DB-Doris

作业类型为 batch，source 使用 Jdbc-Mysql（参数详见 MySQL 数据源文档），sink 使用 Doris-batch。

                JSON
                
            

                {
  "_db_jobMeta": {
    "name": "mysql_to_doris_batch",
    "description": "MySQL orders 表离线同步到 Doris",
    "parentFolderId": "project_91cc_799bd26eee94",
    "type": "batch",
    "mode": "script"
  },
  "env": {
    "job.mode": "BATCH",
    "parallelism": 1,
    "checkpoint.interval": 30000
  },
  "source": [
    {
      "plugin_name": "Jdbc",
      "_db_pluginId": "Jdbc-Mysql",
      "plugin_output": "source_table",
      "_db_connectionId": "mysql-conn-001",
      "_db_sourceDatabase": "sales_db",
      "_db_sourceTable": "orders"
    }
  ],
  "sink": [
    {
      "plugin_name": "Doris",
      "_db_pluginId": "Doris-batch",
      "plugin_input": "source_table",
      "_db_sinkPath": "prod.default",
      "_db_catalog": "prod",
      "_db_schema": "default",
      "_db_isAutoCreated": true,
      "_db_sinkTableType": "MANAGED",
      "_db_sinkNameRule": "SAME",
      "_db_comment": "订单表"
    }
  ]
}
            

Writer 参数：Doris-batch

参数	描述	是否必选	默认值
`plugin_name`	SeaTunnel 插件名，固定填 `Doris`	是	无
`_db_pluginId`	DataBuilder 侧插件 ID，固定填 `Doris-batch`	是	无
`plugin_input`	对应 source 的 `plugin_output` 值	是	无
`_db_sinkPath`	目标 Catalog 和 Schema，格式为 `{catalog}.{schema}`，如 `prod.default`	是	无
`_db_catalog`	目标 Catalog 名称	是	无
`_db_schema`	目标 Schema 名称	是	无
`_db_isAutoCreated`	是否自动建表：`true`（自动建表）/ `false`（选择已有表）	否	`true`
`_db_sinkTableType`	表类型，当前固定为 `MANAGED`（托管表）	否	`MANAGED`
`_db_sinkNameRule`	目标表命名规则：`SAME` / `ADD_PREFIX` / `ADD_SUFFIX` / `ADD_PREFIX_AND_SUFFIX` / `CUSTOM`	否	`SAME`
`_db_prefix`	表名前缀，`_db_sinkNameRule` 含 `ADD_PREFIX` 时生效	否	无
`_db_suffix`	表名后缀，`_db_sinkNameRule` 含 `ADD_SUFFIX` 时生效	否	无
`_db_sinkTableName`	自定义表名，`_db_sinkNameRule=CUSTOM` 时使用	否	无
`_db_sinkTable`	选择已有目标表，`_db_isAutoCreated=false` 时使用	否	无
`_db_comment`	目标表描述（可选）	否	无

二、实时任务：MySQL-CDC → DB-Doris

作业类型为 streaming，source 使用 MySQL-CDC（参数详见 MySQL 数据源文档），sink 使用 Doris-streaming。

                JSON
                
            

                {
  "_db_jobMeta": {
    "name": "mysql_cdc_to_doris_streaming",
    "description": "MySQL orders 表 CDC 同步到 Doris",
    "parentFolderId": "folder_af42_bccdb16a1d00",
    "type": "streaming",
    "mode": "script",
    "syncMode": "BASE_INCREMENT"
  },
  "env": {
    "job.mode": "STREAMING",
    "parallelism": 1,
    "_db_enableCheckpoint": false
  },
  "source": [
    {
      "plugin_name": "MySQL-CDC",
      "_db_pluginId": "MySQL-CDC",
      "plugin_output": "source_table",
      "_db_connectionId": "mysql-cdc-conn-001",
      "_db_sourceDatabase": "sales_db",
      "_db_syncMode": "BASE_INCREMENT"
    }
  ],
  "sink": [
    {
      "plugin_name": "Doris",
      "_db_pluginId": "Doris-streaming",
      "plugin_input": "source_table",
      "_db_sinkPath": "prod.default",
      "_db_catalog": "prod",
      "_db_schema": "default",
      "_db_sinkTableType": "MANAGED"
    }
  ],
  "_db_tableConfigs": [
    {
      "tableIdentity": {
        "sourceTable": "orders",
        "sinkTable": "ods_orders"
      },
      "sink": {
        "_db_isAutoCreated": true,
        "_db_sinkNameRule": "SAME",
        "_db_dmlConfig": {
          "insert": "INSERT",
          "update": "UPDATE",
          "delete": "DELETE",
          "logicalDeleteTag": ""
        }
      }
    }
  ]
}
            

Writer 参数：Doris-streaming

sink[0] 全局参数

参数	描述	是否必选	默认值
`plugin_name`	SeaTunnel 插件名，固定填 `Doris`	是	无
`_db_pluginId`	DataBuilder 侧插件 ID，固定填 `Doris-streaming`	是	无
`plugin_input`	对应 source 的 `plugin_output` 值	是	无
`_db_sinkPath`	目标 Catalog 和 Schema，格式为 `{catalog}.{schema}`，如 `prod.default`	是	无
`_db_catalog`	目标 Catalog 名称	是	无
`_db_schema`	目标 Schema 名称	是	无
`_db_sinkTableType`	表类型，当前固定为 `MANAGED`（托管表）	否	`MANAGED`

表级配置（写入 _db_tableConfigs[i].sink）

参数	描述	可选值	默认值
`_db_isAutoCreated`	是否自动建表	`true` / `false`	`true`
`_db_sinkNameRule`	目标表命名规则	`SAME` / `ADD_PREFIX` / `ADD_SUFFIX` / `ADD_PREFIX_AND_SUFFIX` / `CUSTOM`	`SAME`
`_db_prefix`	表名前缀	任意字符串	无
`_db_suffix`	表名后缀	任意字符串	无
`_db_sinkTable`	选择已有目标表，`_db_isAutoCreated=false` 时使用	任意字符串	无
`_db_comment`	目标表描述（可选）	任意字符串	无
`_db_dmlConfig.insert`	INSERT 事件处理策略	`INSERT` / `IGNORE`	`INSERT`
`_db_dmlConfig.update`	UPDATE 事件处理策略	`UPDATE` / `IGNORE`	`UPDATE`
`_db_dmlConfig.delete`	DELETE 事件处理策略；逻辑删除会写入 `logical_delete_tag` 字段	`DELETE` / `IGNORE` / `LOGICAL_DELETE`	`DELETE`

配置编写注意事项

plugin_name 相同，_db_pluginId 不同：Doris-batch 和 Doris-streaming 的 plugin_name 均为 Doris，通过 _db_pluginId 区分。
Streaming 表级配置：流式写入的建表方式、命名规则、DML 策略均在 _db_tableConfigs[i].sink 中配置，不在 sink[0] 中配置。

评价此篇文章

有帮助没帮助

DB-媒体集

DB-结构化数据集

百度智能云

百度胜算