Rule engine example

    Only the following operations are applicable in EMQX:

    • Check (debug)
    • Send data to a web service
    • Bridge data to a MQTT Broker

    The rest are exclusive to EMQX Enterprise.

    Create a rule for testing: print the content of the message and all the args of the action, when a MQTT message is sent to topic ‘t/a’.

    • The filter SQL is: SELECT * FROM “message.publish” WHERE topic = ‘t/a’;
    • The action is: “print the content of the message and all the args of the action”, the action we need is ‘inspect’.

    The CLI above created a rule with ID=’Rule rule:803de6db’.

    The first two args are mandatory:

    • SQL: SELECT * FROM “message.publish” WHERE topic = ‘t/a’
    • Action List: [{“name”:”inspect”, “params”: {“a”: 1}}]. Action List is of type JSON Array. “name” is the name of the action, “params” is the parameters of the action. Note that the action does not need a resource.

    The last arg is an optional description of the rule: ‘Rule for debug’.

    If a MQTT message “hello” is sent to topic ‘t/a’, the rule “Rule rule:803de6db” will be matched, and then action “inspect” will be triggered, the following info will be printed to the emqx console:

    1. $ tail -f log/erlang.log.1
    3. (emqx@127.0.0.1)1> [inspect]
    4. Selected Data: #{clientid => <<"shawn">>,event => 'message.publish',
    5.                     id => <<"5898704A55D6AF4430000083D0002">>,
    6.                     payload => <<"hello">>,
    7.                     peername => <<"127.0.0.1:61770">>,qos => 1,
    8.                     timestamp => 1558587875090,topic => <<"t/a">>,
    9.                     username => undefined}
    10. Envs: #{event => 'message.publish',
    12.         from => <<"shawn">>,
    13.         headers =>
    14.             #{allow_publish => true,
    15.                 peername => {{127,0,0,1},61770},
    16.                 username => undefined},
    17.         id => <<0,5,137,135,4,165,93,106,244,67,0,0,8,61,0,2>>,
    18.         timestamp => {1558,587875,89754},
    19.         topic => <<"t/a">>}
    20. Action Init Params: #{<<"a">> => 1}
    • Selected Data listed the fields that selected by the SQL.All available fields will be listed here, as we used .
    • Envs is the environment variables that can be used internally in the action.
    • Action Init Params is the params we passed to the action.

    Send data to WebHook

    Setup a Web Service, here we setup a simple web service using the linux tool nc:

    Create a rule:

    Select “message.publish”, then type in the following SQL:

    1. SELECT
    2.     *
    3. FROM
    4.     "message.publish"

    Bind an action:

    Click on the “+ Add” button under “Action Handler”, and then select “Data to Web Server” in the pop-up dialog window.

    image

    Bind a resource to the action:

    Since the dropdown list “Resource” is empty for now, we create a new resource by clicking on the “New Resource” to the top right, and then select “WebHook”:

    Configure the resource:

    And click on the “Testing Connection” button to make sure the connection can be created successfully, and then click on the “Create” button.

    image

    Back to the “Actions” dialog, and then click on the “Confirm” button.

    Back to the creating rule page, then click on “Create” button. The rule we created will be show in the rule list:

    image

    We have finished, testing the rule by sending an MQTT message to emqx:

    1. Topic: "t/1"
    3. QoS: 1

    Then inspect the Web Service table, verify a new record has been received:

    image