使用Node-OPCUA向西门子OPCUA服务器写变量报错：类型未定义

问题背景 #

使用node-opcua开发的OPCUA客户端可正常连接并读取所有数据类型，但写入节点时仅Int系列（全类型）、Bool类型可正常处理，String、Byte等类型写入失败。核心写入逻辑代码如下：

app.post("/api/write-node", ensureOpcuaSession, async (req, res) => {
  const { nodeId, value, dataType = "String" } = req.body;

  if (!nodeId) {
    return res.status(400).json({ error: "nodeId is required" });
  }

  if (value === undefined) {
    return res.status(400).json({ error: "value is required" });
  }

  try {
    console.log(
      `Writing to node ${nodeId}: value=${JSON.stringify(
        value
      )}, dataType=${dataType}`
    );
    const session = req.opcuaSession;

    // Determine the actual data type to use
    let opcuaDataType;
    switch (dataType) {
      case "Boolean":
        opcuaDataType = DataType.Boolean;
        break;
      case "Byte":
        opcuaDataType = DataType.Byte;
        break;
      case "SByte":
        opcuaDataType = DataType.SByte;
        break;
      case "Int16":
        opcuaDataType = DataType.Int16;
        break;
      case "UInt16":
        opcuaDataType = DataType.UInt16;
        break;
      case "Int32":
        opcuaDataType = DataType.Int32;
        break;
      case "UInt32":
        opcuaDataType = DataType.UInt32;
        break;
      case "Int64":
        opcuaDataType = DataType.Int64;
        break;
      case "UInt64":
        opcuaDataType = DataType.UInt64;
        break;
      case "Float":
        opcuaDataType = DataType.Float;
        break;
      case "Double":
        opcuaDataType = DataType.Double;
        break;
      case "String":
        opcuaDataType = DataType.String;
        break;
      case "DateTime":
        opcuaDataType = DataType.DateTime;
        break;
      default:
        opcuaDataType = DataType.String;
    }

    // Determine if it's an array
    const isArray = Array.isArray(value);
    const arrayType = isArray
      ? VariantArrayType.Array
      : VariantArrayType.Scalar;

    // Write the value to the node
    const statusCode = await session.write({
      nodeId,
      attributeId: AttributeIds.Value,
      value: {
        value: {
          dataType: opcuaDataType,
          arrayType: arrayType,
          value: value,
        },
      },
    });

    return res.json({
      success: true,
      nodeId,
      statusCode: statusCode.toString(),
    });
  } catch (err) {
    console.error(`Error writing to node ${nodeId}:`, err.message);
    return res.status(500).json({ error: err.message });
  }
});

解决方法 #

1. 修正基础类型的格式转换 #

node-opcua对Byte、SByte等类型的输入有严格的类型要求，需用对应构造函数封装；String类型需避免传入JSON序列化后的带引号字符串：

// 引入所需类型构造函数
const { DataType, Byte, SByte } = require("node-opcua");

// 修改switch分支的处理逻辑
switch (dataType) {
  // ...其他case保持不变
  case "Byte":
    opcuaDataType = DataType.Byte;
    // 确保值是Byte类型实例，范围0-255
    value = typeof value === "number" ? new Byte(Math.max(0, Math.min(255, value))) : value;
    break;
  case "SByte":
    opcuaDataType = DataType.SByte;
    // 确保值是SByte类型实例，范围-128到127
    value = typeof value === "number" ? new SByte(Math.max(-128, Math.min(127, value))) : value;
    break;
  case "String":
    opcuaDataType = DataType.String;
    // 处理前端可能传入的JSON序列化字符串
    if (typeof value === "string" && value.startsWith('"') && value.endsWith('"')) {
      try {
        value = JSON.parse(value);
      } catch (e) { /* 解析失败则保留原字符串 */ }
    }
    break;
  // ...其他case保持不变
}

2. 使用Variant类构造写入值 #

手动组装value对象容易出现格式错误，改用node-opcua提供的Variant类自动处理序列化：

const { Variant } = require("node-opcua");

// 替换原写入逻辑中的value构造部分
const variant = new Variant({
  dataType: opcuaDataType,
  arrayType: arrayType,
  value: value
});

const statusCode = await session.write({
  nodeId,
  attributeId: AttributeIds.Value,
  value: variant
});

3. 校验节点权限与类型匹配 #

• 检查节点写入权限：先读取节点的UserWriteAccess属性，确认节点允许写入：

  const writeAccessResult = await session.read({
    nodeId,
    attributeId: AttributeIds.UserWriteAccess
  });
  console.log("Node write access:", writeAccessResult.value.value);
  // 若返回值为0，则节点不可写入，需检查服务器配置
  

• 确认节点实际数据类型：避免传入的dataType与节点定义不符，比如服务器节点是ByteString而非String：

  const dataTypeResult = await session.read({
    nodeId,
    attributeId: AttributeIds.DataType
  });
  console.log("Node actual data type:", dataTypeResult.value.value.toString());
  

4. 精细化错误排查 #

捕获错误时打印完整错误信息，包括OPCUA状态码的具体含义：

catch (err) {
  console.error(`Write error for node ${nodeId}:`, err);
  // 解析状态码对应的错误描述
  if (err.statusCode) {
    const { StatusCodes } = require("node-opcua");
    console.error("Status code meaning:", StatusCodes[err.statusCode]);
  }
  return res.status(500).json({ 
    error: err.message, 
    statusCode: err.statusCode?.toString(),
    details: err.stack
  });
}

常见错误状态码如BadTypeMismatch（类型不匹配）、BadNotWritable（无写入权限）可直接定位问题。

内容的提问来源于stack exchange，提问作者Dorian