文件目标(Sink)

目标(Sink)用于将分析结果保存到指定文件中。

编译和部署插件

  1. # cd $kuiper_src
  2. # go build -trimpath --buildmode=plugin -o plugins/sinks/File.so plugins/sinks/file/file.go
  3. # cp plugins/sinks/File.so $kuiper_install/plugins/sinks

重新启动 Kuiper 服务器以激活插件。

属性

属性名称是否可选说明
path保存结果的文件路径,例如 /tmp/result.txt
interval写入分析结果的时间间隔(毫秒)。 默认值为1000,这表示每隔一秒钟写入一次分析结果。

使用示例

下面是一个选择温度大于50度的示例,每5秒将结果保存到文件 /tmp/result.txt 中。

  1. {
  2. "sql": "SELECT * from demo where temperature>50",
  3. "actions": [
  4. {
  5. "file": {
  6. "path": "/tmp/result.txt",
  7. "interval": 5000
  8. }
  9. }
  10. ]
  11. }