问题标签 [bull-queue]

我正在尝试将 redis 免费云实例与公牛队列连接，但由于无法连接而出现错误。

1. 我尝试了以下代码：

对于上面的代码，它给出错误 Error: connect ECONNREFUSED 127.0.0.1:6379 消息。

2. 也尝试过这样的事情：使用 tls 字段但没有用。

注意：我正在使用带有公牛队列的 redis 免费云实例，并且还下载了 redis Insight 桌面应用程序。我已将数据库添加到 redis Insight 桌面应用程序并且它已连接但在节点应用程序中它无法正常工作。我是否缺少任何配置？

当您知道要注册的队列列表时，您可以在 nestjs 模块实例化中使用 registerQueue() 添加它们，但如何动态注册队列，例如。如果我有一个多租户架构，当创建一个新租户时我想动态注册一个新队列，是否可以使用嵌套 js 公牛队列？

如果我使用@OnQueueCompleted()，那么我可以从队列中一个已完成的作业中获得响应，对吗？或者 @Onqueuecompleted() 仅在队列中的所有作业都完成时才响应。

请帮忙

这是我的代码和理解：

因此，如果作业失败，它将重试五次，直到完成。因为退避政策，它会延迟1s,2s,4s,8s...进行重试。我对吗？

每次作业失败时它都会调用@OnQueueFailed() 函数。

比如一个job第一次失败，调用@OnQueueFailed()，等待1s再尝试第二次，失败，再次调用@OnQueueFailed()。它将等待2s并尝试第三次；这一次，它完成并调用@OnQueueCompleted()。

请帮忙

我需要传递命令行参数或参数或 execargv，它们应该在为子进程加载环境时出现在进程参数中，该子进程将由公牛启动以处理作业。

可能吗？如果是，有什么办法吗？

我可以使用包含/bull/lib/process的 args[1] 识别为公牛启动的子进程， 但我想将自定义参数传递给节点进程。

我正在使用 Bull 队列开发 NestJs 项目。这是我用来连接Redis的代码，效果很好。</p>

现在，我需要切换到使用 Redis Sentinel。我在网上搜索，但找不到合适的教程。

感谢您提供的任何帮助。

我正在尝试使用nest.js 中的BullQueue 包来实现一个队列。我有两个队列，一个是文件队列，另一个是电子邮件队列。

上传缩略图后，我使用文件队列在后台重新生成缩略图。和电子邮件队列发送电子邮件。问题是我的文件队列工作得很好，但是我创建的电子邮件队列给了我一个不一致的结果。有时工作会被该@Process('JobName')功能接手，有时则不会。

更重要的是，我注意到当问题发生时，我尝试删除 dist 文件夹并重新启动重新生成 dist 目录的服务器。它工作，直到它没有经过几次试验。

这是我的文件夹结构。

公牛队列.module.ts

电子邮件-producer.service.ts

电子邮件处理器.service.ts

我想知道我是否违反了任何设计原则，或者这只是队列包管理器的问题。

目前，我正在开发一个带有公牛队列的 NestJS 项目。在我的控制器中，我有一个 get 函数来接收来自前端的请求。根据请求，我将发送一个 gRPC 调用以从其他微服务中检索数据。我想让 gRPC 调用函数与公牛队列一起工作。所以，在get函数中，我把gRPC调用函数放到了producer中，可以在consumer中执行。但是在consumer中执行gRPC调用函数后，我找不到办法将检索到的数据返回给之前的get函数，以便将数据发送回前端。

任何帮助，将不胜感激。