百度智能云 Apache Doris 文档百度智能云文档 SQL手册 14 例行导入(Routine Load)功能,支持用户提交一个常驻的导入任务,通过不断的从指定的数据源读取数据,将数据导入到 Doris 中。 目前仅支持通过无认证或者 SSL 认证方式,从 Kakfa 导入 CSV 或 Json 格式的数据。 语法: 导入作业的名称,在同一个 database 内,相同名称只能有一个 job 在运行。 指定需要导入的表的名称。 使用 SSL 连接 Kafka 时,需要指定以下参数: 其中: 和 为必须,用于指明连接方式为 SSL,以及 CA 证书的位 置。 如果 Kafka server 端开启了 client 认证,则还需设置: 分别用于指定 client 的 public key,private key 以及 private key 的密码。 2. 指定kafka partition的默认起始offset 百度智能云文档 SQL手册 18 2. 为 example_db 的 example_tbl 创建一个名为 test1 的 Kafka 例行导入任务。导入任务为严格模式。 3. 通过 SSL 认证方式,从 Kafka 集群导入数据。同时设置 client.id 参数。导入任务为非严格模式,时区为 Africa/Abidjan CREATE CREATE ROUTINE ROUTINE LOAD0 码力 | 203 页 | 1.75 MB | 1 年前3
共 1 条
- 1













