写入Vertica
使用 Flux 向 Vertica 写入数据:
导入
sql包。将数据通过管道传递到
sql.to()并提供以下参数:- driverName: vertica 或 vertigo
- dataSourceName: 查看数据源名称
- table: 要写入的表
- batchSize: 每次调用
Exec时可以排队的参数或列的数量(默认为10000)
import "sql"
data
|> sql.to(
driverName: "vertica",
dataSourceName: "vertica://username:password@localhost:5433/dbname",
table: "public.example_table",
)
Vertica 数据源名称
vertica 和 vertigo 驱动使用以下 DSN 语法(也称为连接字符串):
vertica://<user>:<password>@<host>:<port>/<database>?<queryArgs>
该 vertica 和 vertigo 驱动程序使用 vertica/vertica-sql-go 实现。有关支持的 DSN 查询参数的信息,请参见 vertica/vertica-sql-go 文档。
Flux 到 Vertica 数据类型转换
sql.to() 将Flux数据类型转换为Vertica数据类型。
| Flux 数据类型 | Vertica 数据类型 |
|---|---|
| float | 浮点数 |
| int | 整数 |
| uint | 整数 |
| 字符串 | VARCHAR |
| 布尔型 | BOOL |
| 时间 | TIMESTAMP |