rules.md 2.6 KB

规则管理

Kuiper规则命令行工具可以管理规则,例如创建、显示、删除、描述、启动、停止和重新启动规则。

创建规则

如下命令用于创建规则。 规则的定义以JSON 格式指定,请阅读 rule 以获取更多详细信息。

create rule $rule_name $rule_json | create rule $rule_name -f $rule_def_file

可以通过两种方式创建规则。

  • 在命令行中指定规则定义。

示例:

# bin/cli create rule rule1 {"sql": "SELECT * from demo","actions": [{"log":  {}},{"mqtt":  {"server":"tcp://127.0.0.1:1883", "topic":"demoSink"}}]}

该命令创建一个名为rule1的规则。

  • 在文件中明确规则定义。 如果规则很复杂,或者规则已经以组织良好的格式写在文本文件中,则只需通过-f选项指定规则定义即可。

示例:

# bin/cli create rule rule1 -f /tmp/rule.txt

以下是rule.txt的内容。

{
  "sql": "SELECT * from demo",
  "actions": [
    {
      "log": {}
    },
    {
      "mqtt": {
        "server": "tcp://127.0.0.1:1883",
        "topic": "demoSink"
      }
    }
  ]
}

展示规则

该命令用于显示服务器中定义的所有规则。

show rules

示例:

# bin/cli show rules
rule1
rule2

描述规则

该命令用于打印规则的详细定义。

describe rule $rule_name

示例:

# bin/cli describe rule rule1
{
  "sql": "SELECT * from demo",
  "actions": [
    {
      "log": {}
    },
    {
      "mqtt": {
        "server": "tcp://127.0.0.1:1883",
        "topic": "demoSink"
      }
    }
  ]
}

删除规则

该命令用于删除规则。

drop rule $rule_name

示例:

# bin/cli drop rule rule1
rule rule1 dropped

启动规则

该命令用于开始运行规则。

start rule $rule_name

示例:

# bin/cli start rule rule1
rule rule1 started

停止规则

该命令用于停止运行规则。

stop rule $rule_name

示例:

# bin/cli stop rule rule1
rule rule1 stopped

重启规则

该命令用于重启规则。

restart rule $rule_name

示例:

# bin/cli restart rule rule1
rule rule1 restarted

获取规则的状态

该命令用于获取规则的状态。 状态可以是

  • 运行
  • 停止: $reason
getstatus rule $rule_name

示例:

# bin/cli getstatus rule rule1
running