Node-RED flow between Sox and CKAN

sox-ckan-flow.json

[
    {
        "id": "10a5ef39.f60931",
        "type": "function",
        "z": "61f14b03.8125a4",
        "name": "Prep",
        "func": "var device = msg.topic;\nvar transducers = msg.payload;\nvar ckanData = {\n    pressure: 0,\n    temperature: 0,        \n    illuminance: 0,\n    pm2_5: 0,\n    latitude: 0,        \n    longitude: 0,        \n    altitude: 0,\n    speed: 0,\n    device: device,\n    timestamp: 0\n}\n\nfor (var i = 0; i < transducers.length; i++){\n    var trans = transducers[i];\n    if (trans.name === \"Atmospheric Pressure\"){\n        ckanData.pressure = trans.sensorData.rawValue\n    }\n    if (trans.name === \"Atmospheric Temperature\"){\n        ckanData.temperature = trans.sensorData.rawValue\n    }\n    if (trans.name === \"Illuminance\"){\n        ckanData.illuminance = trans.sensorData.rawValue\n    }\n    if (trans.name === \"PM2.5\"){\n        ckanData.pm2_5 = trans.sensorData.rawValue\n    }\n    if (trans.name === \"Longitude\"){\n        ckanData.longitude = trans.sensorData.rawValue\n    }\n    if (trans.name === \"Latitude\"){\n        ckanData.latitude = trans.sensorData.rawValue\n    }\n    if (trans.name === \"Altitude\"){\n        ckanData.altitude = trans.sensorData.rawValue\n    }\n    if (trans.name === \"Speed\"){\n        ckanData.speed = trans.sensorData.rawValue\n    }\n    ckanData.timestamp = new Date().getTime(trans.sensorData.timestamp)/1000\n}\n    \nreturn {payload: ckanData};",
        "outputs": 1,
        "noerr": 0,
        "x": 210,
        "y": 60,
        "wires": [
            [
                "95095392.adf4a"
            ]
        ]
    },
    {
        "id": "6dafa1ca.35cfa",
        "type": "ckants insert",
        "z": "61f14b03.8125a4",
        "resourceId": "59200810-3cb5-4c81-b5ed-ace13a0f169d",
        "name": "",
        "auth": "c55ee6d0.e700e8",
        "x": 650,
        "y": 60,
        "wires": []
    },
    {
        "id": "95095392.adf4a",
        "type": "join",
        "z": "61f14b03.8125a4",
        "name": "Batch Every 2 Seconds",
        "mode": "custom",
        "build": "array",
        "property": "payload",
        "propertyType": "msg",
        "key": "topic",
        "joiner": "\\n",
        "joinerType": "str",
        "accumulate": false,
        "timeout": "2",
        "count": "",
        "x": 410,
        "y": 60,
        "wires": [
            [
                "6dafa1ca.35cfa",
                "4c211ccd.7dc204"
            ]
        ]
    },
    {
        "id": "4c211ccd.7dc204",
        "type": "debug",
        "z": "61f14b03.8125a4",
        "name": "",
        "active": true,
        "console": "false",
        "complete": "false",
        "x": 650,
        "y": 120,
        "wires": []
    },
    {
        "id": "7eec3087.4cf6b",
        "type": "sox in",
        "z": "61f14b03.8125a4",
        "name": "Sox In",
        "device": "carsensor010,carsensor011,carsensor012,carsensor013,carsensor014,carsensor015,carsensor016,carsensor017,carsensor018,carsensor019,carsensor020,carsensor021,carsensor022,carsensor023,carsensor024,carsensor025,carsensor026,carsensor027,carsensor028,carsensor029,carsensor030,carsensor031,carsensor032,carsensor033,carsensor034,carsensor035,carsensor036,carsensor037,carsensor038,carsensor039,carsensor040,carsensor041,carsensor042,carsensor043,carsensor044,carsensor045,carsensor046,carsensor047,carsensor048,carsensor049,carsensor050,carsensor051,carsensor052,carsensor053,carsensor054,carsensor055,carsensor056,carsensor057,carsensor058,carsensor059,carsensor060,carsensor061,carsensor062,carsensor063,carsensor064,carsensor065,carsensor066,carsensor067,carsensor068,carsensor069,carsensor070,carsensor071,carsensor072,carsensor073,carsensor074,carsensor075,carsensor076,carsensor077,carsensor078,carsensor079,carsensor080,carsensor081,carsensor082,carsensor083,carsensor084,carsensor085",
        "transducer": "",
        "login": "",
        "x": 70,
        "y": 60,
        "wires": [
            [
                "10a5ef39.f60931"
            ]
        ]
    },
    {
        "id": "c55ee6d0.e700e8",
        "type": "ckants-credentials",
        "z": "",
        "ckan": "http://bigclout.lancaster.ac.uk/",
        "name": "bigclout"
    }
]