Documentation

写入SQLite

要使用 Flux 将数据写入 SQLite

  1. 导入 sql

  2. 将数据通过管道传递到 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 CloudInfluxDB 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


Flux的未来

Flux 正在进入维护模式。您可以像现在一样继续使用它,而无需对您的代码进行任何更改。

阅读更多

InfluxDB 3 开源版本现已公开Alpha测试

InfluxDB 3 Open Source is now available for alpha testing, licensed under MIT or Apache 2 licensing.

我们将发布两个产品作为测试版的一部分。

InfluxDB 3 核心,是我们新的开源产品。 它是一个用于时间序列和事件数据的实时数据引擎。 InfluxDB 3 企业版是建立在核心基础之上的商业版本,增加了历史查询能力、读取副本、高可用性、可扩展性和细粒度安全性。

有关如何开始的更多信息,请查看: