跳到主要内容
版本：Next

OpenMldb

OpenMldb 源连接器

描述​

用于从 OpenMldb 读取数据.

关键特性​

选项​

名称类型必需默认值描述
cluster_modeboolean是-是否以 OpenMLDB 集群模式连接。
sqlstring是-用于读取数据的 SQL 语句。
databasestring是-数据库名称。
hoststring否-当 cluster_mode 为 false 时必填。
portint否-当 cluster_mode 为 false 时必填。
zk_hoststring否-当 cluster_mode 为 true 时必填。
zk_pathstring否-当 cluster_mode 为 true 时必填。
session_timeoutint否10000OpenMLDB 会话超时时间，单位毫秒。
request_timeoutint否60000OpenMLDB 请求超时时间，单位毫秒。
common-options否-源插件通用参数。

cluster_mode [boolean]​

是否以 OpenMLDB 集群模式连接。为 false 时配置 host 和 port；为 true 时配置 zk_host 和 zk_path。

sql [string]​

Sql 语句

database [string]​

数据库名称

host [string]​

OpenMldb主机，仅支持OpenMldb单模

port [int]​

OpenMldb端口，仅支持OpenMldb单模

zk_host [string]​

Zookeeper主机，仅在OpenMldb集群模式下受支持

zk_path [string]​

Zookeeper路径，仅在OpenMldb集群模式下受支持

session_timeout [int]​

OpenMLDB 会话超时时间，单位毫秒。

request_timeout [int]​

OpenMLDB 请求超时时间，单位毫秒。

common options​

源插件常用参数, 详见 Source Common Options

示例​

source {
  OpenMldb {
    host = "172.17.0.2"
    port = 6527
    sql = "select * from demo_table1"
    database = "demo_db"
    cluster_mode = false
  }
}

集群模式示例：

source {
  OpenMldb {
    zk_host = "zk-1:2181,zk-2:2181,zk-3:2181"
    zk_path = "/openmldb"
    sql = "select * from demo_table1"
    database = "demo_db"
    cluster_mode = true
  }
}

变更日志​

Change Log
ChangeCommitVersion
[improve] openmldb options (#9166)https://github.com/apache/seatunnel/commit/d324fc59a42.3.11
[Improve][Common] Introduce new error define rule (#5793)https://github.com/apache/seatunnel/commit/9d1b2582b22.3.4
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd6010512.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab1665612.3.1
[Feature][Connector] add get source method to all source connector (#3846)https://github.com/apache/seatunnel/commit/417178fb842.3.1
[Feature][API & Connector & Doc] add parallelism and column projection interface (#3829)https://github.com/apache/seatunnel/commit/b9164b8ba12.3.1
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a1192.3.0
[Feature][Conenctor-V2] Add openmldb source connector (#3313)https://github.com/apache/seatunnel/commit/e68ecf7bef2.3.0