保存数据到 Cassandra

    初始化 Cassandra 表:

    创建 “test” 表空间:

    创建 “t_mqtt_msg” 表:

    1. USE test;
    2. CREATE TABLE t_mqtt_msg (
    3.     topic text,
    4.     qos int,
    6.     PRIMARY KEY (msgid, topic)

    创建规则:

    打开 EMQX Dashboard (opens new window)，选择左侧的 “规则” 选项卡。

    填写规则 SQL:

    image

    关联动作:

    填写动作参数:

    “保存数据到 Cassandra” 动作需要两个参数：

    1). 关联资源的 ID。初始状况下，资源下拉框为空，现点击右上角的 “新建资源” 来创建一个 Cassandra 资源。

    image

    填写资源配置:

    Keysapce 填写 “test”，用户名填写 “root”，密码填写 “public” 其他配置保持默认值，然后点击 “测试连接” 按钮，确保连接测试成功。

    2). SQL 模板。这个例子里我们向 Cassandra 插入一条数据，SQL ​ 模板为:

    1. insert into t_mqtt_msg(msgid, topic, qos, payload, arrived) values (${id}, ${topic}, ${qos}, ${payload}, ${timestamp})

    插入数据之前，SQL 模板里的 ${key} 占位符会被替换为相应的值。

    image

    在点击 “新建” 完成规则创建

    现在发送一条数据，测试该规则:

    然后检查 Cassandra 表，可以看到该消息已成功保存:

    image