シナリオ: 正規化されたIoTデータのモニター、コマンドの送信および電子メール・アラート

const PRESSURE_LIMIT = 100;

// Include only Boiler digital twins in this map.
// HVAC pressure records are ignored because their OCIDs are not mapped here.
const boilerExternalKeyMap = {
  "<boiler-01-digital-twin-ocid>": "fr-guide-boiler-01",
  "<boiler-02-digital-twin-ocid>": "fr-guide-boiler-02"
};

const event = msg.payload || {};
const twinOcid = event.digitalTwinInstanceId;
const externalKey = boilerExternalKeyMap[twinOcid];

if (event.contentPath !== "pressure" || !externalKey) {
  return null;
}

const pressure = Number(event.value);
if (!Number.isFinite(pressure) || pressure <= PRESSURE_LIMIT) {
  return null;
}

msg.digitalTwinOcid = twinOcid;
msg.requestEndpoint = `boilers/${externalKey}/command/reset`;
msg.responseEndpoint = `boilers/${externalKey}/command/response`;

msg.title = `Boiler High Pressure Alert - ${externalKey}`;
msg.notificationpayload = {
  alert: "Boiler pressure is above the allowed limit",
  action: "Reset boiler command sent",
  digitalTwinOcid: twinOcid,
  externalKey: externalKey,
  pressure: pressure,
  threshold: PRESSURE_LIMIT,
  timeObserved: event.timeObserved
};

msg.payload = { reset: true };
return msg;

msg.pollDeadline = Date.now() + 70000;
msg.pollCount = 0;
return msg;

70秒の期限は、1分間のレスポンス・ウィンドウと、最終的なデータベース更新の10秒をカバーします。

const rows = Array.isArray(msg.payload) ? msg.payload : [];
const row = rows[0];
msg.pollCount = (msg.pollCount || 0) + 1;

if (!row) {
  if (Date.now() < msg.pollDeadline) {
    return [null, msg];
  }

  msg.payload = [{
    DELIVERY_STATUS: "POLL_TIMEOUT",
    RESET_RESULT: null,
    TIME_FINISHED: null
  }];
  return [msg, null];
}

const status = String(row.DELIVERY_STATUS || "").toUpperCase();
const finalStatuses = [
  "COMPLETED",
  "REJECTED",
  "REFUSED",
  "EXPIRED",
  "BAD_RESPONSE",
  "NOT_RESPONDED"
];

if (finalStatuses.includes(status)) {
  return [msg, null];
}

if (Date.now() >= msg.pollDeadline) {
  msg.payload = [{
    ...row,
    DELIVERY_STATUS: "POLL_TIMEOUT"
  }];
  return [msg, null];
}

return [null, msg];

const row = msg.payload[0] || {};
const alert = msg.notificationpayload || {};
const commandStatus = String(row.DELIVERY_STATUS || "UNKNOWN").toUpperCase();
const resetResult = String(row.RESET_RESULT || "NO_RESPONSE").toUpperCase();
const resetSucceeded = commandStatus === "COMPLETED" && resetResult === "SUCCESS";

let result;
if (resetSucceeded) {
  msg.title = `Boiler High Pressure Alert - Reset Successful - ${alert.externalKey}`;
  result = "The device confirmed that the boiler reset completed successfully.";
} else if (commandStatus === "POLL_TIMEOUT") {
  msg.title = `Boiler High Pressure Alert - Reset Status Timed Out - ${alert.externalKey}`;
  result = "The boiler did not respond to the reset command within the allowed time.";
} else {
  msg.title = `Boiler High Pressure Alert - Reset Failed - ${alert.externalKey}`;
  result = "The device did not confirm a successful boiler reset.";
}

msg.payload = JSON.stringify({
  ...alert,
  result: result,
  commandStatus: commandStatus,
  resetResult: resetResult,
  timeFinished: row.TIME_FINISHED || null
}, null, 2);

return msg;

oci iot flow-runtime update-flows \
  --iot-flow-runtime-id <flow-runtime-ocid> \
  --flows-document file://<path-to-flows-json>

コンソールまたはAPIを使用してフロー・ドキュメントを更新する方法の詳細は、IoTフロー・ランタイムのフローの更新を参照してください。

{
  "reset": "SUCCESS"
}

{
  "alert": "Boiler pressure is above the allowed limit",
  "action": "Reset boiler command sent",
  "digitalTwinOcid": "<boiler-digital-twin-ocid>",
  "externalKey": "fr-guide-boiler-01",
  "pressure": 102,
  "threshold": 100,
  "timeObserved": "<timestamp>",
  "result": "The device confirmed that the boiler reset completed successfully.",
  "commandStatus": "COMPLETED",
  "resetResult": "SUCCESS",
  "timeFinished": "<timestamp>"
}