MQTT Parsing Script

The Go IoT development platform allows users to write parsing scripts for different MQTT clients, and these scripts need to be able to execute correctly. The example program is as follows

function main(nc) {
    var dataRows = [
        { "Name": "Temperature", "Value": "23" },
        { "Name": "Humidity", "Value": "30" },
        { "Name": "A", "Value": nc },
    ];
    var result = {
        "Time":  Math.floor(Date.now() / 1000),
        "DataRows": dataRows,
        "DeviceUid": "5",
        "IdentificationCode":"5",
        "Nc": nc
    };
    return [result];
}

In the above program, the data reported by the MQTT client will be transmitted to the main function in the form of a string (nc is the parameter name). Do not adjust this content.

Regarding the return value, it must contain the data fields Time, DataRows, DeviceUid, and IdentificationCode. Their meanings are as follows:

1. Time: Device data production time, in seconds timestamp.
2. DataRows: Core signal data points. It is an array structure where the keys are Name and Value, Name represents the signal name, and Value represents the signal data value.
3. DeviceUid: MQTT client ID, please correspond to the unique code of the current row of data. Please check carefully

4. IdentificationCode: Device identification code, if your subscription topic does not have a wildcard, please keep this data information consistent with DeviceUid. If a wildcard appears, please differentiate it from DeviceUid.

Note:

1. DeviceUid is hardcoded in the return value. Do not generate it dynamically.
2. IdentificationCode must be differentiated from DeviceUid in principle, i.e., the two cannot be the same.

Data Link

When writing to Influxdb, assemble according to the following data assembly rules.

1. bucket: Project fixed configuration.

2. Measurement: Dynamically calculated as ${protocol}_${DeviceUid}_${IdentificationCode}

func genMeasurement(dt DataRowList, protocol string) string {
	return protocol + "_" + dt.DeviceUid + "_" + dt.IdentificationCode
}