csv.from() 函数
csv.from() 从逗号分隔值 (CSV) 数据源检索数据，并返回表流。
函数类型签名
(?csv: string, ?file: string, ?mode: string) => stream[A] where A: Record
有关更多信息，请参阅函数类型签名。
参数
csv
CSV 数据。
支持带注释的 CSV 或原始 CSV。使用 mode 指定解析模式。
file
要查询的 CSV 文件的文件路径。
路径可以是绝对路径或相对路径。如果为相对路径，则相对于 fluxd 进程的工作目录。CSV 文件必须存在于运行 fluxd 进程的同一文件系统中。
mode
是 CSV 解析模式。默认为 annotations。
可用的注释模式
- annotations：使用 CSV 注释来确定列数据类型。
- raw：将所有列解析为字符串，并将第一行用作标题行，将所有后续行用作数据。
示例
从文件查询带注释的 CSV 数据
import "csv"
csv.from(file: "path/to/data-file.csv")
从 CSV 文件查询原始数据
import "csv"
csv.from(file: "/path/to/data-file.csv", mode: "raw")
查询带注释的 CSV 字符串
import "csv"
csvData =
"
#datatype,string,long,dateTime:RFC3339,dateTime:RFC3339,dateTime:RFC3339,string,string,double
#group,false,false,false,false,false,true,true,false
#default,,,,,,,,
,result,table,_start,_stop,_time,region,host,_value
,mean,0,2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:50:00Z,east,A,15.43
,mean,0,2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:51:00Z,east,A,65.15
,mean,1,2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:50:20Z,east,B,59.25
,mean,1,2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:51:20Z,east,B,18.67
,mean,2,2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:50:40Z,east,C,52.62
,mean,2,2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:51:40Z,east,C,82.16
"
csv.from(csv: csvData)
查询原始 CSV 字符串
import "csv"
csvData =
"
_start,_stop,_time,region,host,_value
2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:50:00Z,east,A,15.43
2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:50:20Z,east,B,59.25
2018-05-08T20:50:00Z,2018-05-08T20:51:00Z,2018-05-08T20:50:40Z,east,C,52.62
"
csv.from(csv: csvData, mode: "raw")
此页是否对您有帮助？
感谢您的反馈！