Node.js中如何简化Redis HMGET查询并将结果转为对象？

1. 简化对象重构 #

封装工具函数，自动将HMGET返回的数组与字段列表对应生成对象，避免手动解构赋值：

async function hmgetToObject(redisClient, key, fields) {
  const values = await redisClient.hmget(key, fields);
  return fields.reduce((obj, field, index) => {
    obj[field] = values[index];
    return obj;
  }, {});
}

// 使用方式
const reconstructUser = await hmgetToObject(ioredis, 'user:1', ['name', 'email', 'level']);

2. 整合类型转换与默认值处理 #

扩展工具函数，通过字段配置对象定义每个字段的转换规则和默认值，一次性解决三个需求：

async function hmgetWithTransform(redisClient, key, fieldConfigs) {
  const fields = Object.keys(fieldConfigs);
  const values = await redisClient.hmget(key, fields);
  
  return fields.reduce((obj, field, index) => {
    const { transform, default: defaultValue } = fieldConfigs[field];
    let value = values[index];

    // 应用默认值
    if (value === null || value === undefined) {
      value = defaultValue ?? null;
    }

    // 执行类型转换
    if (typeof transform === 'function') {
      value = transform(value);
    }

    obj[field] = value;
    return obj;
  }, {});
}

// 使用示例
const reconstructUser = await hmgetWithTransform(ioredis, 'user:1', {
  name: { default: '未知用户' },
  email: { default: 'no-email@example.com' },
  level: { 
    default: 0,
    transform: (val) => val !== null ? parseInt(val, 10) : 0 
  }
});

3. 额外优化：用HGETALL获取全量字段 #

如果需要获取哈希表的所有字段，可改用HGETALL直接拿到原始对象，再针对性处理类型和默认值：

async function hgetallWithTransform(redisClient, key, fieldConfigs) {
  const rawObj = await redisClient.hgetall(key);
  if (!rawObj) return {};

  return Object.entries(fieldConfigs).reduce((obj, [field, config]) => {
    let value = rawObj[field];
    const { transform, default: defaultValue } = config;

    if (value === undefined || value === null) {
      value = defaultValue ?? null;
    }

    if (typeof transform === 'function') {
      value = transform(value);
    }

    obj[field] = value;
    return obj;
  }, {});
}

// 使用示例
const reconstructUser = await hgetallWithTransform(ioredis, 'user:1', {
  name: { default: '未知用户' },
  email: { default: 'no-email@example.com' },
  level: { 
    default: 0,
    transform: parseInt 
  }
});

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