怎么把rest请求参数转json文件,存在data目录下,


写一个规则,使用 HTTP Push 数据源 | eKuiper 文档文件目标(Sink) | eKuiper 文档

不用写规则,,我手动调rest请求触发一下就行了,就是不知道图二具体的代码思路怎么写

你的意思是直接改代码?要写代码的话,直接另写一个专门的程序应该更简单啊。

图二 handler是我自己新加的,我的想法是获取请求参数转成io流,直接写入文件,是这个逻辑吗

不建议。这个本身也跟产品无关了

我现在是有这样的需求,创建一个table就是对应的这个json内容,普通的目录下写文件我知道咋写,但是这个运行的包下 kuiper/_build/kuiper-b111ea5-windows-amd64/data,,我也能直接写进去吗

file sink 配置写入的目录为 data 就可以了,默认的相对路径是相对 eKuiper 根目录的。

路径应该怎么写,我现在生成的在c盘下了

data/abc.json

格式我要怎么定义,文件每一行都有【】了

data 不太对,报错了

什么版本啊?另外输出不用数组的话,配置sink的 sendSingle:true

有问题,一个【】都没有了,,每个json分开了,不是数组了

你的 fileType 是 lines 啊。改成 json 才是 json 文件。文档先看一下吧

哦哦,可以了,路径那个咋弄呢

{
  "id": "ruleFile",
  "sql": "SELECT * FROM mqttDemo",
  "actions": [{
    "file": {
       "path": "data/abc.jsonl",
       "format": "json",
       "fileType": "lines",
       "rollingCount": 1,
       "sendSingle": true
    }
  }]
}

我这样没问题啊。我看你是用代码编译的,你的代码没有更新到最新吧?