写入 SQL 数据库
使用 sql.to() 通过 Flux 将数据写入 SQL 数据库。
数据库
sql.to() 支持以下 SQL 数据库
驱动程序
sql.to() 使用 Go SQL 驱动程序 在 Go sql 包 中连接到 SQL 数据库。以下驱动程序可用
bigqueryhdbmysqlpostgressnowflakesqlite3sqlserver
数据源名称
每个 SQL 驱动程序 都支持唯一的数据源名称 (DSN) 语法（也称为 连接字符串）。有关每个驱动程序的 DSN 信息，请参阅数据库指南。
将敏感凭据存储为密钥
如果使用 InfluxDB Cloud 或 InfluxDB OSS 2.x，我们建议将 DSN 凭据存储为 InfluxDB 密钥。使用 secrets.get() 从 InfluxDB 密钥 API 检索密钥。
import "sql"
import "influxdata/influxdb/secrets"
username = secrets.get(key: "POSTGRES_USER")
password = secrets.get(key: "POSTGRES_PASS")
sql.to(
driverName: "postgres",
dataSourceName: "postgresql://${username}:${password}@localhost:5432",
table: "example_table",
)
数据结构
sql.to() 将所有行取消分组到单个表中，并将所有现有列写入为指定的目标表。如果目标表不存在，sql.to() 将尝试创建它。
列数据类型
每个 sql.to() 驱动程序 将 Flux 基本数据类型 转换为目标数据库支持的相应数据类型。有关数据类型转换的信息，请参阅数据库指南。
示例
给定以下 表流
数据
| _time | tag | _value |
|---|---|---|
| 2021-01-01T00:00:00Z | t1 | -2 |
| 2021-01-01T00:00:10Z | t1 | 10 |
| 2021-01-01T00:00:20Z | t1 | 7 |
| _time | tag | _value |
|---|---|---|
| 2021-01-01T00:00:00Z | t2 | 19 |
| 2021-01-01T00:00:10Z | t2 | 4 |
| 2021-01-01T00:00:20Z | t2 | -3 |
Flux 脚本
import "sql"
data
|> sql.to(
driverName: "mysql",
dataSourceName: "username:passwOrd@tcp(localhost:3306)/db",
table: "exampleTable"
)
SQL 输出
| _time | tag | _value |
|---|---|---|
| 2021-01-01 00:00:00 | t1 | -2 |
| 2021-01-01 00:00:10 | t1 | 10 |
| 2021-01-01 00:00:20 | t1 | 7 |
| 2021-01-01 00:00:00 | t2 | 19 |
| 2021-01-01 00:00:10 | t2 | 4 |
| 2021-01-01 00:00:20 | t2 | -3 |
此页面是否对您有帮助？
感谢您的反馈！