完整的 SCADA，外加一层 IIoT 平台

fn csv_esc(v) {
    let s = v.to_string();
    s.replace(""", """");
    `"${s}"`
}

fn specific_energy(kwh, tonnes) {
    if tonnes <= 0.0 { return (); }
    kwh / tonnes
}

let tz = ctx.timezone;
let rows = [];

for tag in shift.tags {
    if tag.quality != "good" { continue; }
    rows.push([
        tag.name,
        csv_esc(tag.value),
        tag.ts.to_local(tz),
    ]);
}

emit_report("shift_summary", rows);

export function transform(msg) {
  const { deviceId, payload, ts } = msg;

  const tags = Object.entries(payload)
    .filter(([, v]) => v !== null && v !== "")
    .map(([key, value]) => ({
      key: `${deviceId}/${key}`,
      value: Number(value),
      ts,
    }));

  const bad = tags.filter((t) => Number.isNaN(t.value));
  if (bad.length) {
    ctx.warn(`dropped ${bad.length} non-numeric tags`);
  }

  return { tags: tags.filter((t) => !Number.isNaN(t.value)) };
}