rabbitmq 相关问题

RabbitMQ是一个开源消息代理,最初实现AMQP协议,并通过插件架构支持其他消息传递协议。此标记应与涉及RabbitMQ服务器消息代理产品的问题一起使用,或者与RabbitMQ产品的源代码和实现有关的问题一起使用。诸如amqp或mqtt之类的特定协议标签也可以是适当的,以及正在使用的OS和编程语言。

芹菜任务时间慢

我正在使用 Django、Celery 和 RabbitMQ。我有一个发送电子邮件的简单任务。该任务有效,但速度非常慢。 例如,我发送 5000 封电子邮件,所有 5000 封电子邮件都直接发送到 RabbitMQ 作为规范...

回答 2 投票 0

MassTransit 为工作消费者展示 LIFO(后进先出)顺序

在我的 .NET Core 应用程序中,我使用 MassTransit Job Consumer 来运行一些长时间运行的作业。然而,我注意到同时提交的作业(几秒钟之内)似乎是

回答 1 投票 0

RabbitMQ。是否可以为多个队列配置consumer并指定优先级?

是否可以设置为消费者首先从第一个队列接收消息,然后从第二个队列接收消息,然后从第三个队列接收消息?即,使得不同队列中的消息具有不同的

回答 1 投票 0

尝试从.net core 5应用程序连接aws mq上的rabbit mq时出现异常

我在尝试连接到rabbitmq时遇到了这个异常。我的应用程序在 .NET 5 上运行。 我不使用私有 vpc 我已将 mq 设置为公共 异常:指定的端点均未响应...

回答 2 投票 0

删除celery中所有待处理的任务?

如何在不知道每个任务的task_id的情况下删除所有待处理的任务?

回答 12 投票 0

PRECONDITION_FAILED:使用 Gevent 和并发在 Celery 和 RabbitMQ 上传递确认超时

我刚刚从 ForkPool 切换到 gevent,并发性 (5) 作为在 Kubernetes Pod 中运行的 Celery 工作线程的池方法。切换后,我在工作人员中遇到了不可恢复的错误:

回答 3 投票 0

RabbitMq-服务器所需的功能标志未启用!升级 RabbitMQ 之前必须启用它

当我尝试按照本指南在Debian和Ubuntu上安装rabbitmq-server时遇到了这个问题,但是当我尝试执行systemctl startrabbitmq-server.service或rabbitmq-server时

回答 1 投票 0

RabbitMQ 错误:“ssl_options.keyfile 无效,文件不存在或节点无法读取”

我正在尝试通过 Docker Compose 将 SSL 添加到 RabbitMQ 部署: #rabbitmq.conf ssl_options.certfile = /container/path/to/certfile.crt ssl_options.keyfile = /容器/路径/到/密钥文件....

回答 1 投票 0

Azure 服务总线:在 Node.js 中实现优先级队列(类似于 RabbitMQ)

我正在尝试使用 Node.js 在 Azure 服务总线中实现优先级队列,类似于我使用 RabbitMQ 实现的效果。在 RabbitMQ 中,我可以为消息分配优先级,确保我的优先级高...

回答 1 投票 0

通过 RabbitMQ 进行 H.264 视频流的发布和订阅速率问题

我正在开发一个项目,使用 RabbitMQ(AMQP 协议)传输 H.264 视频文件并将其显示在 Web 应用程序中。该设置包括捕获视频帧、对其进行编码、将其发送到

回答 1 投票 0

无法将用户添加到 RabbitMQ 中的默认虚拟主机

我想使用 REST API 将用户添加到 RabbitMQ 中的默认/虚拟主机。 我正在执行以下端点: PUT http://localhost:15672/api/permissions/%2F/user.name 我得到: 400 坏

回答 1 投票 0

我的 python 实例毫无例外地在 [_model(torch.zeros(1, 3, self.image_size, self.image_size).to(_selected_device).half().half())]

这是我的内存、CPU、GPU 和 Torch 版本信息: 内存总计:30794980 kB 内存空闲:26650464 kB 内存可用:28247716 kB 缓冲区:73680 kB 缓存:1840696 kB 交换C...

回答 1 投票 0

基于优先级的队列

我正在尝试为使用 Discord API 的 Discord 相关任务实现一个基于队列的解决方案。需要一些关于如何实施的意见。 这是对它的期望 D...

回答 1 投票 0

RabbitMQ 利用消费者应用程序中的多个消费者线程

我如何从一个消费者应用程序中利用多个消费者线程, 这是我的代码 这是我的主要函数,我只调用 3 个线程并给出函数 ConsumeMessages 但它最终使用...

回答 1 投票 0

如何检查作为 Docker 容器运行的 RabbitMQ 的队列

有没有办法为rabbitmq的Docker容器运行rabbitmqctl?我无法检查我的队列。 另外,这个命令有什么特别之处: docker run -it --rm --namerabbitmq -p 5672:5672 -p 15672:

回答 2 投票 0

RabbitMQ 远程连接到 Lightsail(Ubuntu 实例)时出现错误

我有这个 urls RMQ 选项,它在本地 MacOs 机器上运行良好 { urls: ['amqp://127.0.0.1'] } 然后我在 AWS Lightsail (Ubuntu) 的远程计算机上安装了 RMQ 并打开了必要的端口

回答 1 投票 0

如何在 docker compose 中使用主机名连接到 RabbitMQ 流插件

我正在遵循以下示例:https://rabbitmq.github.io/rabbitmq-stream-dotnet-client/stable/htmlsingle/index.html 我的应用程序通过 docker compose 运行: 例如 版本:'3.8' 服务...

回答 1 投票 0

开玩笑 RabbitMq AmqpConnection 模拟失败

我正在开发一个与 RabbitMQ 交互的 NestJS 应用程序。我已经为我的一个 API 编写了测试用例,并且正在尝试模拟 AmqpConnection。然而,由于某种原因,测试仍然无法进行...

回答 1 投票 0

RabbitMq 集群操作员和 loadBalancerIP

我正在尝试获取配置了负载均衡器 IP 的 RabbitMq 集群(我知道它在某些时候已被弃用,但这还不是很明显),并且我在获取服务定义时遇到问题...

回答 1 投票 0

异步方法后的代码未执行

下面是我的代码,在异步调用await InvokeMyRpcClientAsync(inputNumber)之后,其余代码在调试模式下不会被命中(也在控制台中也不会打印文本): 等待 MyFiboRpcCa...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.