Skip to content

Latest commit

 

History

History
39 lines (29 loc) · 1.11 KB

file.md

File metadata and controls

39 lines (29 loc) · 1.11 KB

File Sink

The sink is used for saving analysis result into a specified file.

Compile & deploy plugin

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

Restart the Kuiper server to activate the plugin.

Properties

Property name Optional Description
path false The file path for saving the result, such as /tmp/result.txt
interval true The time interval (ms) for writing the analysis result. The default value is 1000, which means write the analysis result with every one second.

Sample usage

Below is a sample for selecting temperature great than 50 degree, and save the result into file /tmp/result.txt with every 5 seconds.

{
  "sql": "SELECT * from demo where temperature>50",
  "actions": [
    {
      "file": {
        "path": "/tmp/result.txt",
        "interval": 5000
      }
    }
  ]
}