シナリオ: オブジェクト・ストレージからのバッチ・データの取込み

deviceType,externalId,time,cpuUtil,memUtil,diskUtil,firmware,temperature,humidity,pressure,mode
gateway,fr-guide-gw-01,1773768299143534,33,28,22,Oracle Linux 9.1,,,,
hvacs,fr-guide-hvac-01,1773768299144534,,,,,70.5,44.2,101.1,cool
hvacs,fr-guide-hvac-02,1773768299145534,,,,,78.3,52.0,100.7,heat

let index = flow.get("iotFileIndex") || 1;

let objectName = `iot-data-${index}.csv`;

msg.fileIndex = index;
msg.objectName = objectName;
msg.payload = objectName;

return msg;

const current = msg.fileIndex || flow.get("iotFileIndex") || 1;

flow.set("iotFileIndex", current + 1);

msg.processedObjectName = msg.objectName;
return msg;

const row = msg.payload || {};

const deviceType = String(row.deviceType || "").trim();
const externalId = String(row.externalId || "").trim();

if (!deviceType || !externalId) {
  node.warn("Skipping CSV row with missing deviceType or externalId");
  return null;
}

const timeValue = Number(row.time || Date.now() * 1000);

if (deviceType === "gateway") {
  msg.topic = "data";
  msg.payload = {
    time: timeValue,
    cpuUtil: Number(row.cpuUtil || 0),
    memUtil: Number(row.memUtil || 0),
    diskUtil: Number(row.diskUtil || 0),
    firmware: row.firmware || "unknown"
  };
} else if (deviceType === "hvacs") {
  msg.topic = "hvacs/" + externalId;
  msg.payload = {
    time: timeValue,
    temperature: Number(row.temperature || 0),
    humidity: Number(row.humidity || 0),
    pressure: Number(row.pressure || 0),
    mode: row.mode || "unknown"
  };
} else {
  node.warn("Unsupported CSV deviceType: " + deviceType);
  return null;
}

msg.payload = JSON.stringify(msg.payload);
return msg;