sql.from() 函数

sql.from() 从 SQL 数据源检索数据。

函数类型签名

(dataSourceName: string, driverName: string, query: string) => stream[A]

参数

driverName

（必需）用于连接到 SQL 数据库的驱动程序。

支持的驱动程序:

• awsathena
• bigquery
• hdb
• mysql
• postgres
• snowflake
• sqlite3 （不适用于 InfluxDB OSS 或 InfluxDB Cloud）
• sqlserver
• vertica, vertigo

dataSourceName

（必需）用于连接到 SQL 数据库的数据源名称 (DNS) 或连接字符串。

query

（必需）针对 SQL 数据库运行的查询。