# 文件源
eKuiper 提供了内置支持,可将文件内容读入 eKuiper 处理管道。 文件源通常用作 表格, 并且采用 create table 语句的默认类型。
CREATE TABLE table1 (
name STRING,
size BIGINT,
id BIGINT
) WITH (DATASOURCE="lookup.json", FORMAT="json", TYPE="file");
1
2
3
4
5
2
3
4
5
文件源的配置文件是 /etc/sources/file.yaml ,可以在其中指定文件的路径。
default:
fileType: json
# 文件以 eKuiper 为根目录的目录或文件的绝对路径。
# 请勿在此处包含文件名。文件名应在流数据源中定义
path: data
# 读取文件的时间间隔,单位为ms。 如果只读取一次,则将其设置为 0
interval: 0
1
2
3
4
5
6
7
2
3
4
5
6
7
通过这个 yaml 文件,该表将引用文件 ${eKuiper}/data/lookup.json 并以 json 格式读取它。
本页导航