连接到 Redis 与多个工作线程一起使用时遇到问题

2024-07-04

我在使用 Heroku 中的 kue 连接到 redis 来处理多个工作进程时遇到问题。我可以在本地主机上与多个工作人员连接到 redis,但在与 redis-to-go 连接时似乎会中断。只有当我运行多个 kue 工作线程/进程时,这似乎才会中断。

kue.redis.createClient = function() {
  var client;
  client = redis.createClient(1234, 'tetra.redistogo.com');
  client.auth('xyz');
  return client;
};


jobs = kue.createQueue();
jobs.process("email, 2, function(job, done) {
  console.log("processing email");
  return done(null, null);
});

收到错误

Error: Uncaught, unspecified 'error' event.
    at RedisClient.emit (events.js:47:15)
    at Command.callback (/Users/transformer/Projects/Pictorious/Services/node_modules/redis/index.js:159:29)
    at RedisClient.return_error (/Users/transformer/Projects/Pictorious/Services/node_modules/redis/index.js:446:25)
    at RedisReplyParser. (/Users/transformer/Projects/Pictorious/Services/node_modules/redis/index.js:256:14)
    at RedisReplyParser.emit (events.js:64:17)
    at RedisReplyParser.send_error (/Users/transformer/Projects/Pictorious/Services/node_modules/redis/lib/parser/javascript.js:266:14)
    at RedisReplyParser.execute (/Users/transformer/Projects/Pictorious/Services/node_modules/redis/lib/parser/javascript.js:125:22)
    at RedisClient.on_data (/Users/transformer/Projects/Pictorious/Services/node_modules/redis/index.js:422:27)
    at Socket. (/Users/transformer/Projects/Pictorious/Services/node_modules/redis/index.js:66:14)
    at Socket.emit (events.js:64:17)

如果您使用 Redis To Go nano 实例(例如免费实例),您可能会遇到连接限制。你只允许 10 个连接,而且 kue 似乎做了很多 redis.client() 操作。所以,你可能会达到这个极限。

要确定,请添加redis.debug_mode = true;在你做任何工作之前,看看输出是什么(注意:它会吐出很多信息,因为有很多连接发生,但是“最大连接”错误在输出末尾或附近)。

至少当我们有一个工作人员和客户端都访问 kue 时,我们似乎达到了这个限制。

希望这可以帮助。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

连接到 Redis 与多个工作线程一起使用时遇到问题 的相关文章

随机推荐

  • 在 Ruby 中对数组使用冒泡排序方法 [关闭]

    Closed 这个问题需要多问focused help closed questions 目前不接受答案 我正在尝试将冒泡排序方法实现为 Ruby 的一个简单编码问题 但遇到了一些麻烦 我理解这个想法是查看第一个元素的值并将其与第二个元素的
  • 将指针转换为64位整数,为什么在32位和64位平台上结果不同

    我有一个这样的代码片段 up cpp include
  • 如何将打印的 C 控制台导入到红色节点

    我在 pi 上使用 Dragino rpi Lora 收发器 C 代码来向 Arduino 发送和接收数据包 C 代码运行良好 打印接收到的数据包 信噪比和时间戳 但我想在节点 red 中使用它 如何将接收到的数据包从 C 控制台导入到红色
  • Pandas:处理测试中看不见的数据

    我有一个训练数据集 正在构建一些机器学习模型 我无权访问测试集 并且想要处理在训练中未观察到测试中的分类特征之一的可能性 这是一个玩具示例 说明了我的意思 我有一个数据框 old 像这样 old pd DataFrame car Audi
  • 如何在C#中隐藏文件?

    我想在c 中隐藏一个文件 我知道文件路径并且可以创建 FileInfo 对象 我怎样才能隐藏它 之前接受的答案 File SetAttributes path FileAttributes Hidden 将导致它可能丢失某些其他属性 因此您
  • 如何命名类似工厂的方法? [关闭]

    Closed 这个问题是基于意见的 help closed questions 目前不接受答案 我猜大多数类似工厂的方法都是从create 但为什么他们被称为 create http dictionary reference com bro
  • 如何在引导程序使用jquery中单击另一个链接时更改活动类?

    我有一个 html 作为侧边栏 并使用Bootstrap ul class nav nav list li class active a href Link 1 a li li a href link2 Link 2 a li li a h
  • ' 为 '
    '?' aria-label='preg_replace '

    ' 为 '
    '?'> preg_replace '

    ' 为 '
    '?

    我的代码删除了 p 起始标签 但现在我想替换结尾 p 带换行符的标签 我怎样才能做到这一点 这就是我所拥有的 content This is the content newcontent preg replace
  • CSS 100% 高度,带填充/边距

    使用 HTML CSS 如何制作一个宽度和 或高度为其父元素 100 且仍具有适当的填充或边距的元素 正确 是指如果我的父元素是200px高 我指定height 100 with padding 5px我希望我应该得到一个190px高元素与
  • 使用 dbt 中的星形宏获取列名称和类型

    使用星形宏 除了列名之外 有没有办法还获取列数据类型 布尔值 数值等 例如 此查询使用星号宏从引用表中收集列名 并将其保存为数组变量column names 然后循环该数组并将 max 函数应用于所有列 set column names s
  • kmlLayer 导致焦点改变(谷歌地图 api v3)

    我将 NOAA 雷达信息分层在焦点为 8 的地图上 加载页面时 地图最初在 8 处渲染 然后立即重新绘制自身以显示整个区域 我使用的 KML 文件包含最小 最大纬度 经度坐标 用于绘制雷达图像 在本例中是美国东南部地区 如果我更改这些坐标以
  • 在 firefox-extension 的新选项卡中打开链接

    我开发了一个网络应用程序来将其用作 Firefox 扩展 在 Firefox 中 我将它包含在 iframe 中 如下所示 现在我想在我的应用程序中有一些传出链接 如果我只使用普通的链接标记 例如 a href http mywebapp
  • 如何在SQL中搜索日期?

    我有一个我想要的事件管理系统 如果某个活动注册了 5 天 2009 年 1 月 21 日至 2009 年 1 月 26 日 那么如果另一个人想要在 2009 年 1 月 22 日至 24 日期间注册活动 则不允许注册 我想使用 SQL 查询
  • 如何使用 Google App Script 在 Google Drive 中创建大文件?

    我正在尝试使用 Google Apps 脚本在 Google Drive 中创建一个大文件 该文件合并了三个文件 我的代码是 function unirFicheros idDirectorio nombreFichero numeroFi
  • django value_list 外键中所有字段

    我有一个类 它有另一个类的外键 class MyEvent models Model msg models ForeignKey MyMessage event type models IntegerField choices EVENTS
  • QTreeView、QFileSystemModel、setRootPath 和 QSortFilterProxyModel 以及用于过滤的 RegExp

    我需要显示特定目录的 QTreeView 并且我想让用户能够使用 RegExp 过滤文件 据我了解 Qt 文档 我可以使用标题中提到的类来实现这一点 如下所示 Create the Models QFileSystemModel fileS
  • 通过key查询模型

    我想做的是查询数据存储中的模型 其中密钥是not我已经拥有的对象的密钥 这是一些代码 class User db Model partner db SelfReferenceProperty def text message self ms
  • ASM 16Bit 将输入缓冲区字符串转换为数字

    也许有人可以帮助我 我正在尝试打印 用户输入的数量 所以我需要将字符串转换为数字 我正在尝试循环执行此操作 但遇到一些问题 我的代码无法正常工作 它正在打印 65535 基本上这是最大值 也许有人可以解释我的问题出在哪里 MODEL sma
  • 将矩阵的每一列乘以另一个矩阵

    我有一个M x N矩阵 我想将每个相乘N列由aM x M矩阵 以下在循环中执行此操作 但我不知道如何对其进行矢量化 u repmat sin 2 pi f t n 1 W rand n answer size u for i 1 size
  • 连接到 Redis 与多个工作线程一起使用时遇到问题

    我在使用 Heroku 中的 kue 连接到 redis 来处理多个工作进程时遇到问题 我可以在本地主机上与多个工作人员连接到 redis 但在与 redis to go 连接时似乎会中断 只有当我运行多个 kue 工作线程 进程时 这似乎