Kuiper 0.4.1 正式发布 - 超轻量IoT边缘流处理
日期:2020/6/1
Kuiper 团队宣布发布 Kuiper 0.4.1
Kuiper 0.4.1 可以从这里下载。
EMQX Kuiper 是 Golang 实现的轻量级物联网边缘分析、流式处理开源软件,可以运行在各类资源受限的边缘设备上。Kuiper 设计的一个主要目标就是将在云端运行的实时流式计算框架(比如 Apache Spark,Apache Storm 和 Apache Flink 等)迁移到边缘端。Kuiper 参考了上述云端流式处理项目的架构与实现,结合边缘流式数据处理的特点,采用了编写基于源 (Source)
,SQL (业务逻辑处理)
, 目标 (Sink)
的规则引擎来实现边缘端的流式数据处理。
网址:https://github.com/lf-edge/ekuiper
Github仓库: https://github.com/emqx/kuiper
概览
Kuiper 0.4.1 版本主要修复了一些从社区中反馈的问题。
功能
- 支持插件多实例的功能。之前的版本中,插件只支持单个实例,现在用户可以通过返回一个构造函数来支持插件多实例功能。
- 修复规则文档中关于
dataTemplate
使用方法的说明 - 修复 EdgeX 浮点数据在某些情况下不能处理的问题
- 支持通过 Docker 环境变量来修改 EdgeX MQTT 消息总线的配置
- 支持将汇聚函数的运算结果作为别名,然后在 WHERE 或者 HAVING 表达式中使用别名进行引用,这样可以避免多次运算,提高了运行效率
- 删除不存在的流、规则时返回 404,而非之前的 400
- 修复了删除规则后,未成功发送的数据被无限重发的问题
- 支持在
SELECT *
的时候,可以根据流中字段定义,实际发送的数据中字段的大小写进行正确处理 - 修复同一类型的 sink,无法准确发送消息的问题
- http_pull 源支持,可以定时从 HTTP rest 接口中拉取数据
感谢
@worldmaomao 提供了浮点运算的修复
联系
如果对Kuiper有任何问题,请随时通过contact@emqx.io与我们联系。