【问题标题】:NodeJS Redis (ioredis) hgetall throwing undefined errorNodeJS Redis (ioredis) hgetall 抛出未定义的错误
【发布时间】:2021-10-22 08:12:41
【问题描述】:

我正在构建一个使用 ioredis 模块连接到 Redis 集群的 NodeJS 应用程序。

问题概述:

  • 对缓存中不存在的键的查找查询按预期返回空对象
  • 对存在缓存的键的查找查询引发错误,但错误未定义。

我创建了一个控制器来创建和管理连接:

const redis = require('ioredis');
const consoleLogger = require('../logger/logger.js').console;

const redisCtrl = {};

redisCtrl.defaultPrefix = 'lookup:';

// Local variable to store the full time connection to Redis for lookups
let _redisClient;

// Redis connection config
redisCtrl.redisConnect = {
  port: process.env.REDIS_PORT || 6379,
  host: process.env.REDIS_HOST,
  password: process.env.REDIS_PASSWORD
};

// Redis config
redisCtrl.redisConfig = {
  dnsLookup: (address, callback) => callback(null, address),
  redisOptions: {
    tls: process.env.REDIS_SSL === 'false' ? false : true,
    password: process.env.REDIS_PASSWORD,
    maxRetriesPerRequest: 1
  }
};

// Retrieve the redis connection
redisCtrl.redisClient = async () => {
  if (!_redisClient) {
    _redisClient = await redisCtrl.getNewConnect();
  }
  return _redisClient;
}

redisCtrl.getNewConnect = async () => {
  let makeConnection;

  if (process.env.REDIS_CLUSTER === 'true') {
    makeConnection = new redis.Cluster([redisCtrl.redisConnect], redisCtrl.redisConfig);
  } else {
    makeConnection = new redis(redisCtrl.redisConnect);
  }

  makeConnection.on("connect", function (err) {
    if (!err) {
      consoleLogger.info("REDIS connected");
    } else {
      consoleLogger.info("REDIS connection error");
      consoleLogger.error(JSON.stringify(err));
    }
  });

  makeConnection.on("error", function (error) {
    consoleLogger.info("REDIS error");
    consoleLogger.error(JSON.stringify(error));
    throw new Error(error);
  });

  return makeConnection;
}

redisCtrl.closeInstance = (cb) => {
  if (_redisClient) {
    _redisClient.quit(cb);
  }
}

module.exports = redisCtrl;

这可以建立连接。

但是,当尝试获取结果时,hgetall 方法会抛出一个空错误。

/**
 * Lookup asset by assetId in Redis cache
 * Return asset data object
 * @param {str} assetId
 */
assetsCtrl.lookupByAssetId = async (assetId) => {
  // Prepend default cache prefix to lookup value
  const lookupKey = `${redisPrefix || `lookup:`}${assetId}`;
  let cachedAsset;
  try {
    cachedAsset = await assetsCtrl.redisClient.hgetall(lookupKey);
  } catch (e) {
    consoleLogger.error(`Lookup by assetId failed. Lookup key: ${lookupKey}`);
    consoleLogger.error(e);
    throw new Error(e);
  }
  return cachedAsset;
}

错误被抛出,但错误未定义。 redisClient.hgetall(lookupKey) 行的“catch”块被调用,但错误未定义。

error: Lookup by assetId failed. Lookup key: lookup:test123456789
**error: undefined {"command":{"name":"hget","args":["lookup:test123456789"]}}**

问题:如何解决此问题?如何查看正在抛出的错误的详细信息?

【问题讨论】:

  • 您是否在调试器中跟踪库中准确抛出错误的位置?
  • 你的redis服务器版本是多少?
  • 你可以使用'redis-cli'连接到redis服务器,然后从那里执行相同的命令吗?我想验证存储的值实际上是“哈希”,而不是“列表”或“集合”等其他东西。
  • @SuyashGaur 谢谢,它实际上不是哈希,因此 hgetall 命令不起作用。我将其更改为 .get 并且有效。我认为问题在于错误消息未定义,所以我被抛弃了,我认为它可能在某个地方迷路了,但我现在应该可以继续了。非常感谢!

标签: node.js redis ioredis


【解决方案1】:

如上述 cmets 所述,
hgetall() 不起作用,因为与 lookup 值对应的数据类型不是 hash

将其更改为 get() 已解决此问题。

【讨论】:

    猜你喜欢
    • 2014-06-01
    • 2020-05-26
    • 2014-07-09
    • 2014-04-02
    • 2014-05-30
    • 2018-11-15
    • 1970-01-01
    • 2019-12-23
    相关资源
    最近更新 更多