不用写规则,,我手动调rest请求触发一下就行了,就是不知道图二具体的代码思路怎么写
你的意思是直接改代码?要写代码的话,直接另写一个专门的程序应该更简单啊。
图二 handler是我自己新加的,我的想法是获取请求参数转成io流,直接写入文件,是这个逻辑吗
不建议。这个本身也跟产品无关了
我现在是有这样的需求,创建一个table就是对应的这个json内容,普通的目录下写文件我知道咋写,但是这个运行的包下 kuiper/_build/kuiper-b111ea5-windows-amd64/data,,我也能直接写进去吗
file sink 配置写入的目录为 data 就可以了,默认的相对路径是相对 eKuiper 根目录的。
data/abc.json
什么版本啊?另外输出不用数组的话,配置sink的 sendSingle:true
你的 fileType 是 lines 啊。改成 json 才是 json 文件。文档先看一下吧
哦哦,可以了,路径那个咋弄呢
{
  "id": "ruleFile",
  "sql": "SELECT * FROM mqttDemo",
  "actions": [{
    "file": {
       "path": "data/abc.jsonl",
       "format": "json",
       "fileType": "lines",
       "rollingCount": 1,
       "sendSingle": true
    }
  }]
}
我这样没问题啊。我看你是用代码编译的,你的代码没有更新到最新吧?
 
        





