0.16.1 • Public • Published


    Node-Red nodes for various functions:

    • Data Analysis - statistical metrics that has real time option
    • Transform
    • Test
    • Load Injector
    • Monitor Flow
    • append
    • Spawn Process
    • Host Available
    • node.js os metrics
    • Levenshtein Distance

    Data Analysis

    Real time metrics which are recalculated on single of data point and posted in msg.result. Key and value can be selected from msg.payload. Sending message with topic"@stats" places message with all stats on second port. If realtime metrics then a third port is shown where the message is sent if it is an outlier being outside 3 standard deviations from mean. This can be changed to median and number of deviations.

    Data Analysis Realtime Data Analysis Pearson R

    A set of data analysis functions that can be run over an array of data

    Single value metrics:

    • Average/Mean
    • Maximum
    • Median
    • Minimum
    • Range
    • Standard Deviation
    • Skewness
    • Sum
    • Variance

    Array metrics:

    • Deltas
    • Deltas Normalised
    • Moving Average Simple (SMA)
    • Moving Average Cumulative (CMA)
    • Moving Average Weighted (WMA)
    • Moving Average Exponential (EMA/EWMA)
    • Normalise
    • Standardization (Z-score Normalization)

    Array data

    • distances
    • minimum distance(s) between points
    • maximum distance(s) between points

    Data Analysis


    Data Analysis Realtime example

    Data Analysis Pearson R example

    Data Analysis example


    Translates a selected msg property to a target property. Messages generates a message for each row or record.


    • Array to CSV
    • Array to HTML
    • Array to ISO8385
    • Array to Messages
    • Array to xlsx / xlsx object (excel uses xlsx)
    • AVRO to JSON (uses avsc)
    • Confluence to JSON
    • CSV to Array
    • CSV to HTML
    • CSV to Messages
    • CSVWithHeader to Array
    • CSVWithHeader to HTML
    • CSVWithHeader to JSON
    • ISO8385 to Array
    • ISO8385 to JSON
    • JSON to Array
    • JSON to Confluence
    • JSON to CSV
    • JSON to AVRO (uses avsc)
    • JSON to ISO8385
    • JSON to Messages
    • JSON to String
    • JSON to xlsx / xlsx object (excel uses xlsx)
    • JSON to XML (uses fast-xml-parser)
    • String to JSON
    • path to Basename
    • path to Dirname
    • path to Extname
    • path to Format
    • path to Is Absolute
    • path to Join
    • path to Parse
    • path to Normalize
    • path to Resolve
    • snappy compress (uses snappy, must install separately)
    • snappy uncompress (uses snappy, must install separately)
    • xlsx / xlsx object to array/JSON (excel uses xlsx)
    • XML to JSON (uses fast-xml-parser)

    Note, snappy needs to be installed separately as can have issues with auto install as build binaries.

    With xlsx object one can use the function in xlsx against the object in functions node.

    Example AVRO with schema

    Transform AVRO

    For Confluence schema contains a list of schemas in form {"",}


    Allows a test case for a message to allow simple testing of nodes. Injects a new message via mouse or message. Message sent to first port which can be consumed by other nodes and returned back to node in a loop. The Test node then checks against detailed expected payload result.



    Test example

    after run

    Test example run


    Append file(s) to payload. Cached to maximise performance. Require can be used to find file.


    Test example:

    append example

    Levenshtein Distance

    The levenshtein distance between two character strings.

    Levenshtein Distance

    Load Injector

    Inject messages for a set period of time with varying think time. Primary purpose is testing and useful for load/stress testing.

    Load Injector

    Test example:

    Load Injector example

    Monitor Flow

    Add on wire between two flows to see message rates in status line. Rate sampled every second and provides rate last second / 10 seconds / 1 minute / 5 minutes.

    Monitor Flow

    Test example:

    Monitor Flow example

    Spawn Process

    Spawn process as per node.js manual with ability to set working directory, environment variables and argument passed to process. STDOUT and STDERR are sent as individual messages. RC port is sent a message on closure. Takes in messages that starts a process with ability to add environment values. Message can be sent to kill the process.

    Spawn Process

    Test example:

    Spawn Process example

    Host Available

    Test if host is available sending msg to up or down port so action can be taken. Message only sent on state change or if message is sent which doesn't have topic refreshHostAvailable. This topic forces a check rather than time check which can be set.

    Host Available

    Test example:

    Host Available example


    The metrics from node.js os


    Test example:

    os example


    Run the following command in the root directory of your Node-RED install

    npm install node-red-contrib-prib-functions


    Test/example flow in test/generalTest.json


    0.16.10 data analysis add eulcidean distance functions. Add array pairs

    0.16.0 fix data analysis variance and stddev, add sample, add tests

    0.14.2 fix general test flows. Add icon for data analysis

    0.14.1 fix capitalization issue with levenshtein Distance

    0.14.0 add xlsx transformer

    0.13.0 Confluence AVRO message converter

    0.12.0 added xml to json and json to xml. Make snappy installed separately as can cause install issues

    0.11.1 Fix spelling of AVRO.

    0.11.0 Transform for AVRO and snappy. Add JSON to CSV

    0.10.2 Transform validate for array source, bug fixes on transform and add improvements to array to messages. Added node for levenshtein distance.

    0.10.1 Real time weighted moving average, levenshtein Distance, for test allow testing of "infinity","-infinity" and "NaN" in JSON.

    0.10.0 Many fixes to transform. Array and csv to various forms work. Added test to validate. Improved test to allow for escape to put special characters into a string.

    0.9.6 Enhance transform with csv ignore lead or trailing lines. Add Array and CSV to Messages. Add in topic override

    0.9.5 Enhance transform with path and setting source and target. Outlier allowed to set number of deviations if median and reset or set stats Add outlier detection and Pearson R realtime metrics.

    0.8.1 Add realtime metrics to data analysis.


    • fix json to table html and minor code improvements. turn off debug mode on spawn process. clear down timer on close for host available
    • add Host Available


    • add Spawn Process
    • improve experimental transform with json to table html


    • test node add select property tested for result
    • dataAnalysis add property analysed
    • add experimental transform

    0.4.0 Add test, monitor flow, data analysis

    0.0.1 base


    Peter Prib


    npm i node-red-contrib-prib-functions

    DownloadsWeekly Downloads






    Unpacked Size

    1.3 MB

    Total Files


    Last publish


    • peter.prib