ekuiper官方文档:https://ekuiper.org/docs/zh/latest/#%E7%90%86%E8%A7%A3-ekuiper

概念:
source:目前支持mqtt、mq(社区1.7有推出http源)
sink动作:支持http(pull)、mqtt、Neuron、EdgeX、内存(Redis)、日志等
rule:可定义一系列sink动作(action)
stream:数据流(无界)
table:可分为无界和有界,有界则指的是静态源数据的快照,无界则是动态源会动态变化
SQL:当创建和管理流或表源时,SQL DDL和DML被用来作为命令的有效载荷。查看流和表以了解详情。
在这里插入图片描述主要使用过程:1、创建流/表
create stream [name] ‘( column args[]) with (format=“json”……)’ ;
其中:args指接受数据名称及类型,with括号后面跟是数据参数包含数据格式(format)、数据来源(datasource)、数据源类型(type)等
2、创建规则(rule)
规则可指定json文件
create rule [name] -f filename
简化流程:
数据流——>source(监听)——>rules(Job)——>sink动作(Action)——>目标

更多推荐