2023-04-14 weekly demo

[ngjaying]

• Demo: Using expression for array index in SQL to allow dynamic index (Yisaer)
• Demo: Limit SQL source/sink max connections to prevent breaking DB when having massive rules (Yisaer)
• Demo: Delay function/node to work with rate limited system (Jiyong)
• Demo: Kafka sink to publish data to Kafka (Jianxiang)

Recording: https://zoom.us/rec/share/-yyHrtMlLLnqV-Fw0i3rvrLR9WK8xN48zopu4N8KnK_Bz6THOZ3b_yP-wTP36N5g.v_oTP1hEql8Osr-e

[ngjaying]

3. Rule of delay function example:

### Create the topic
POST http://{{host}}/streams
Content-Type: application/json

{"sql":"CREATE STREAM mqttDemo() WITH (TYPE=\"mqtt\",FORMAT=\"json\",DATASOURCE=\"demo/#\",SHARED=\"true\");"}

### Create the rule
POST http://{{host}}/rules
Content-Type: application/json

{
  "id": "ruleDelay",
  "sql": "SELECT *, delay(random(), tstamp()) as ts FROM mqttDemo",
  "actions": [{
    "mqtt": {
       "server": "tcp://127.0.0.1:1883",
      "topic": "result/delay/rule",
      "sendSingle": true
    }
  }]
}