zoukankan      html  css  js  c++  java
  • EdgexGo2.0学习17 Kuiper基本使用

    一、安装Kuiper
    通过 https://github.com/lf-edge/ekuiper/releases (opens new window)获取安装包
    1.上传安装包到服务器
    2.解压安装包
    3.cd /kuiper-1.3.1-linux-amd64/bin执行sudo ./kuiperd &
    您应该会看到一条成功的消息:Serving Rule server on port 20498

    二、运行查询
    运行的第一个规则流
    安装emqx服务
    https://www.emqx.com/zh/downloads?product=broker获取安装包
    1.上传安装包到服务器
    2.解压安装包
    3.启动服务
    创建demo流
    $ bin/kuiper create stream demo '(temperature float, humidity bigint) WITH (FORMAT="JSON", DATASOURCE="demo")'
    现在已经创建了流,可以通过 kuiper query 命令对其进行测试。键入kuiper query后,
    显示 kuiper提示符。
    在 kuiper提示符下,您可以键入 SQL 并根据流验证 SQL
    select count(*), avg(humidity) as avg_hum, max(humidity) as max_hum from demo where temperature > 30 group by TUMBLINGWINDOW(ss, 5);

    测试,使用mqtt工具连接mqtt服务,发送
    image
    {"temperature":59, "humidity": 80}

    三、测试结果
    image

    本博客是个人工作中记录,遇到问题可以互相探讨,没有遇到的问题可能没有时间去特意研究,勿扰。
    另外建了几个QQ技术群:
    2、全栈技术群:616945527,加群口令abc123
    2、硬件嵌入式开发: 75764412
    3、Go语言交流群:9924600

    闲置域名www.nsxz.com出售(等宽等高字符四字域名)。
  • 相关阅读:
    left join问题
    SQL索引
    数据库查询优化
    define and inline
    程序的内存分配
    __closure
    this指针
    java笔记
    Visual Studio Code(VSCODE)语言设置
    Excel 2010如何打开多个独立窗口?
  • 原文地址:https://www.cnblogs.com/zhaogaojian/p/15514246.html
Copyright © 2011-2022 走看看