保存数据到 HStreamDB

    更多详细信息，请参考HStream官网数据保存到 HStreamDB - 图2 访问链接 (opens new window)。

    部署参考文档 (opens new window)，可使用 docker 本地部署，或云主机部署。 使用命令创建出 hstream-client :

    进入控制台

    2.      / / / / ___/_  __/ __ \/ ____/   |  /  |/  /
    3.     / /_/ /\__ \ / / / /_/ / __/ / /| | / /|_/ /
    4.   /_/ /_//____//_/ /_/ |_/_____/_/  |_/_/  /_/
    7. Command
    9.   :q                           To exit command line interface

    创建 stream：

    image

    点击，规则引擎 > 规则 > 。 编辑规则 SQL：

    1. SELECT
    3.   payload
    5. FROM

    文档中的规则 SQL 仅作为示例，请按照业务设计编写 SQL。

    点击添加动作，选择数据持久化，保存数据到 HSTreamDB。 选择上一步中创建的资源，并输入参数，参数定义见下表：

    点击确定，创建。

    现在使用 MQTT 桌面客户端 连接至 EMQX，发送一条数据。

    点击规则监控

    image

    这时数据已经写入 HStreamDB，使用任意消费方式，将消息消费出来。文档中使用的是基于 HStream golang SDK 编写的简单消费工具 ，读者可自行按照熟悉的编程语言编写消费端。可见消费日志如下：

    1. {"level":"info","ts":1656311005.5250711,"msg":"[f1]","recordId":"[BatchId: 8589934593, BatchIndex: 0, ShardId: 1317059070792293]","payload":"Hello HSreamDB !"}