Connecting to the Cloud

Before sending data to Ubidots, you need to set up your device and integration within the HARDWARIO Cloud. This tutorial will walk you through each step required to connect via a webhook connector. If you have not yet completed the initial Cloud setup steps, you can follow the instructions here: HARDWARIO Cloud Documentation.

Step-by-Step Instructions

Create a New Connector

To establish communication with Ubidots, go to the Connectors section in the left-hand menu.
Click + New Connector and configure the following:
• Name – give your connector a name
• Type – select Webhook for Ubidots integration
• Trigger – choose Data
• Tag – assign the tag you created earlier
Transform Data for Ubidots Format

Ubidots requires a specific data format. You need to adjust your device data using a transformation code.
In the connector page, scroll down to the Transformation section and click the magnifying glass icon 📄🔍 to open the code editor.
Insert the Transformation Code

Add the transformation logic that converts incoming data to a Ubidots-compatible format.

Example of transformation code here:

function main(job) {
  let body = job.message.body;
  const timemultiply = 1000;
  const sharedtimestamp = new Date(job.message.created_at).getTime();
  const sn = job.device.label.ubidots;
  const token = "ENTER YOUR TOKEN HERE";

// Configuration: choose whether to send last N points or the older remaining points
  const MAX_POINTS_PER_SERIES = 2;
  const SEND_REST = false; // false = send last N, true = send rest of the data

const dataMap = {};
  // Include both 'avg' for sensor averages and 'value' for count-type measurements
  const allowedKeys = ["avg", "value"];

function getTimestamp(possibleTimestamp) {
      return (typeof possibleTimestamp === 'number' && !isNaN(possibleTimestamp))
          ? possibleTimestamp * timemultiply
          : sharedtimestamp;
  }

function pushToData(variable, value, timestamp) {
      if (value == null) return;
      if (!dataMap[variable]) dataMap[variable] = [];
      dataMap[variable].push({ value, timestamp });
  }

function flattenAndPush(prefix, obj, timestamp, filterKeys = null) {
      for (const [key, val] of Object.entries(obj || {})) {
          if (filterKeys && !filterKeys.includes(key)) continue;
          pushToData(`${prefix}.${key}`, val, timestamp);
      }
  }

// Common CHESTER parameters: only when sending last N points
  if (!SEND_REST) {
      flattenAndPush("system", body.system, sharedtimestamp);
      flattenAndPush("message", body.message, sharedtimestamp);
      flattenAndPush("attribute", body.attribute, sharedtimestamp);
      flattenAndPush("backup", body.backup, sharedtimestamp);
      flattenAndPush("thermometer", body.thermometer, sharedtimestamp);
      flattenAndPush("accelerometer", body.accelerometer, sharedtimestamp);
      flattenAndPush("network.parameter", body.network?.parameter, sharedtimestamp);
      flattenAndPush("network", { imei: body.network?.imei, imsi: body.network?.imsi }, sharedtimestamp);
  }

// BLE Tags
  body.ble_tags?.forEach((tag, i) => {
      processSeries(`ble_tags.${i}.humidity`, tag.humidity?.measurements);
      processSeries(`ble_tags.${i}.temperature`, tag.temperature?.measurements);
  });

// Generic multi-sensor handler
  const sensorTypes = ['w1_thermometers', 'analog_channels', 'rtd_thermometer', 'weight', 'counter', 'current', 'voltage'];
  sensorTypes.forEach(type => {
      body[type]?.forEach((entry, i) => {
          const id = entry.serial_number || entry.channel || i;
          processSeries(`${type}.${id}`, entry.measurements);
      });
  });

// Buttons (single values)
  if (!SEND_REST) {
      body.buttons?.forEach((btn, i) => {
          flattenAndPush(`button_${i}`, btn, sharedtimestamp);
      });
  }

// Nested sensors
  const nestedSensors = [
      ['weather_station', ['wind_speed', 'wind_direction', 'rainfall']],
      ['hygrometer', ['temperature', 'humidity']],
      ['barometer', ['pressure']],
      ['radon_probe', ['chamber_humidity', 'chamber_temperature', 'concentration_daily', 'concentration_hourly']],
      ['iaq_sensor', ['temperature', 'humidity', 'illuminance', 'altitude', 'pressure', 'co2_conc', 'motion_count', 'press_count']],
      ['soil_sensors', ['moisture', 'temperature']]
  ];
  nestedSensors.forEach(([sensorKey, fields]) => {
      const sensor = body[sensorKey];
      if (!sensor) return;
      fields.forEach(field => {
          processSeries(`${sensorKey}.${field}`, sensor[field]?.measurements);
      });
  });

// Convert to Ubidots payload format
  const result = {};
  for (const [key, datapoints] of Object.entries(dataMap)) {
      result[key] = datapoints.length === 1 ? datapoints[0] : datapoints;
  }

return {
      method: "POST",
      url: `https://industrial.api.ubidots.com/api/v1.6/devices/${sn}`,
      header: {
          "X-Auth-Token": token,
          "Content-Type": "application/json"
      },
      data: result
  };
}

Set Ubidots Token in Headers
Make sure to include your Ubidots device token in the header of the transformation code to authorize data transmission.

Assign Devices to Connector
Scroll down and select which devices (with the matching tag) should be connected.
On the left side, you'll see incoming data from the device.
On the right side, you'll see the transformed data being sent to Ubidots.

Once everything is properly configured, your device’s data should begin flowing into Ubidots automatically.

tip

You can test the data by opening your device in Ubidots and checking whether the variables are being updated in real-time.

Step-by-Step Instructions​

Create a New Connector​

Transform Data for Ubidots Format​

Insert the Transformation Code​

Set Ubidots Token in Headers​

Assign Devices to Connector​

Step-by-Step Instructions

Create a New Connector

Transform Data for Ubidots Format

Insert the Transformation Code

Set Ubidots Token in Headers

Assign Devices to Connector