1.0.7 • Published 10 months ago

node-red-contrib-context-redis v1.0.7

Weekly downloads
-
License
ISC
Repository
github
Last release
10 months ago

Redis plugin

The Redis plugin holds context data in the Redis.

Pre-requisite

To run this you need a Redis server running. For details see the Redis site.

Install

  1. Run the following command in your Node-RED user directory - typically ~/.node-red

    npm install node-red-contrib-context-redis

  2. Add a configuration in settings.js:

contextStorage: {
    custom: {
        module: require("node-red-contrib-context-redis"),
        config: {
            // see below options
        }
    }
}

Options

This plugin exposes some options defined in node_redis as itself options. It needs following configuration options:

OptionsDescription
hostThe IP address of the Redis server. Default: "127.0.0.1"
portThe port of the Redis server. Default: 6379
dbThe Redis logical database to connect. Default: 0
prefixIf set, the string used to prefix all used keys.
usernameIf set, the plugin will run Redis AUTH command on connect. Note: the username will be sent as plaintext.
passwordIf set, the plugin will run Redis AUTH command on connect. Note: the password will be sent as plaintext.

see https://github.com/NodeRedis/node_redis#options-object-properties

Example

        contextStorage: {
            custom: {
                module: require("node-red-contrib-context-redis"),
                config: {
                    prefix: process.env.APP_NAME || "appname",
                    host: process.env.REDIS_HOST || "localhost",
                    port: process.env.REDIS_PORT || 6379,
                    db: process.env.REDIS_DB || 0,
                    username: process.env.REDIS_USERNAME || "",
                    password: process.env.REDIS_PASSWORD || "",
                    // see below options
                }
            }
        },

Data Model

Node-RED                      Redis
+-------------------+         +-------------------------------+
| global context    |         | logical database              |
| +---------------+ |         | +---------------------------+ |
| | +-----+-----+ | |         | | +-----------------+-----+ | |
| | | key |value| | | <-----> | | | global:key      |value| | |
| | +-----+-----+ | |         | | +-----------------+-----+ | |
| +---------------+ |         | |                           | |
|                   |         | |                           | |
| flow context      |         | |                           | |
| +---------------+ |         | |                           | |
| | +-----+-----+ | |         | | +-----------------+-----+ | |
| | | key |value| | | <-----> | | | <flow's id>:key |value| | |
| | +-----+-----+ | |         | | +-----------------+-----+ | |
| +---------------+ |         | |                           | |
|                   |         | |                           | |
| node context      |         | |                           | |
| +---------------+ |         | |                           | |
| | +-----+-----+ | |         | | +-----------------+-----+ | |
| | | key |value| | | <-----> | | | <node's id>:key |value| | |
| | +-----+-----+ | |         | | +-----------------+-----+ | |
| +---------------+ |         | +---------------------------+ |
+-------------------+         +-------------------------------+
  • This plugin uses a Redis logical database for all context scope.
  • This plugin prefixes all used keys with context scope in order to identify the scope of the key.
    • The keys of global context will be prefixed with global: . e.g. Set "foo" to hold "bar" in the global context -> Set "global:foo" to hold "bar" in the Redis logical database.
    • The keys of flow context will be prefixed with <id of the flow>: . e.g. Set "foo" to hold "bar" in the flow context whose id is 8588e4b8.784b38 -> Set "8588e4b8.784b38:foo" to hold "bar" in the Redis.
    • The keys of node context will be prefixed with <id of the node>: . e.g. Set "foo" to hold "bar" in the node context whose id is 80d8039e.2b82:8588e4b8.784b38 -> Set "80d8039e.2b82:8588e4b8.784b38:foo" to hold "bar" in the Redis.

Data Structure

  • This plugin converts a value of context to JSON and stores it as string type to the Redis.
  • After getting a value from the Redis, the plugin also converts the value to an object or a primitive value.
Node-RED                                 Redis
+------------------------------+         +---------------------------------------------+
| global context               |         | logical database                            |
| +--------------------------+ |         | +-----------------------------------------+ |
| | +--------+-------------+ | |         | | +---------------+---------------------+ | |
| | | str    | "foo"       | | | <-----> | | | global:str    | "\"foo\""           | | |
| | +--------+-------------+ | |         | | +---------------+---------------------+ | |
| | | num    | 1           | | | <-----> | | | global:num    | "1"                 | | |
| | +--------+-------------+ | |         | | +---------------+---------------------+ | |
| | | nstr   | "10"        | | | <-----> | | | global:nstr   | "\"10\""            | | |
| | +--------+-------------+ | |         | | +---------------+---------------------+ | |
| | | bool   | false       | | | <-----> | | | global:bool   | "false"             | | |
| | +--------+-------------+ | |         | | +---------------+---------------------+ | |
| | | arr    | ["a","b"]   | | | <-----> | | | global:arr    | "[\"a\",\"b\"]"     | | |
| | +--------+-------------+ | |         | | +---------------+---------------------+ | |
| | | obj    | {foo,"bar"} | | | <-----> | | | global:obj    | "{\"foo\",\"bar\"}" | | |
| | +--------+-------------+ | |         | | +---------------+---------------------+ | |
| +--------------------------+ |         | +-----------------------------------------+ |
+------------------------------+         +---------------------------------------------+

Other Redis client(e.g. redis-cli) can get the value stored by Node-RED like followings.

Node-RED

global.set("foo","bar");
global.set("obj",{key:"value"});

flow.set("name","alice")
await flow.get("name")

msg.payload = {}
global.set("fookey","globalfooval")
flow.set("fookey","flowfooval")
msg.payload.fookey = await global.get("fookey")
msg.payload.flowfookey = await flow.get("fookey")
console.log(await global.get("fookey"))
console.log(await flow.get("fookey"))
return msg;

redis-cli

redis> GET global:foo
"\"var\""
redis> GET global:obj
"{\"key\":\"value\"}"
redis>
1.0.7

10 months ago

1.0.6

11 months ago

1.0.5

11 months ago

1.0.4

11 months ago

1.0.3

11 months ago

1.0.2

11 months ago

1.0.1

11 months ago

1.0.0

11 months ago