写入 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 没有文件系统访问权限,查询将返回类似于以下错误之一的错误
Error: unable to open database file
failed to read file: filesystem service is uninitialized
An internal error has occurred
如果使用 InfluxDB Cloud 或 InfluxDB OSS,则 Flux 进程不具有文件系统访问权限。
SQLite 数据源名称
sqlite3
驱动程序使用以下 DSN 语法(也称为连接字符串)
file:/path/to/example.db?param=value
Flux 到 SQLite 数据类型转换
sql.to()
将 Flux 数据类型转换为 SQLite 数据类型。
Flux 数据类型 | SQLite 数据类型 |
---|---|
float | FLOAT |
int | INT |
uint | INT |
string | TEXT |
time | DATETIME |
此页面是否对您有帮助?
感谢您的反馈!