不用写规则,,我手动调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
}
}]
}
我这样没问题啊。我看你是用代码编译的,你的代码没有更新到最新吧?