写入SQLite
要使用 Flux 将数据写入 SQLite:
导入
sql包。将数据通过管道传递到
sql.to()并提供以下参数:- driverName: sqlite3
- dataSourceName: 查看数据源名称
- table: 要写入的表
- batchSize: 每次调用
Exec时可以排队的参数或列的数量 (设置为999或更少)
import "sql"
data
|> sql.to(
driverName: "sqlite3",
dataSourceName: "file:/path/to/example.db?cache=shared&mode=ro",
table: "example_table",
)
需要文件系统访问
要查询SQLite,Flux必须能够访问文件系统。 如果Flux无法访问文件系统,查询将返回类似以下的错误:
错误:无法打开数据库文件读取文件失败:文件系统服务未初始化发生内部错误
如果使用InfluxDB Cloud或InfluxDB OSS,Flux 进程不可以访问文件系统。
SQLite 数据源名称
sqlite3 驱动程序使用以下 DSN 语法(也称为 连接字符串):
file:/path/to/example.db?param=value
Flux到SQLite数据类型转换
sql.to() 将Flux数据类型转换为SQLite数据类型。
| Flux 数据类型 | SQLite 数据类型 |
|---|---|
| float | 浮点数 |
| int | 整型 |
| uint | 整数 |
| string | 文本 |
| 时间 | DATETIME |