Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
Celery 3.0.1 中的框架错误
我最近从 2 3 0 升级到 Celery 3 0 1 所有任务都运行良好 很遗憾 我经常收到 帧错误 异常 我还运行主管来重新启动线程 但由于这些线程从未真正被杀死 主管无法知道 celery 需要重新启动 有没有人见过这个 2012 0
python
django
rabbitmq
Celery
如何触发 IModel.BasicAcks?
我第一次使用 RabbitMQ 的 NET API 我想出了一个对我来说似乎合理的用例 我想创建发布消息并在消息被确认后执行某些操作的发布者 IModel BasicAcks 事件似乎是了解这一点的好方法 所以 我给出版商写了一封信 pri
c
NET
rabbitmq
如何在 celery task.apply_async 中使用优先级
我有一个testcelery 中的队列 我为它定义了一个任务 celery app task queue test ignore result True def priority test priority print priority 它
python
rabbitmq
Queue
Celery
PriorityQueue
如何根据条件限制并发消息消耗
场景 我已经简化了事情 许多最终用户可以从前端 Web 应用程序 生产者 开始工作 繁重的工作 例如渲染大型 PDF 这些作业被发送到单个持久的 RabbitMQ 队列 许多工作应用程序 消费者 处理这些作业并将结果写回到数据存储中 这个相
rabbitmq
springrabbit
我应该在 Django 项目中使用 Celery 还是 Carrot?
我有点困惑我应该使用哪一个 我认为两者都可以 但其中一个比另一个更好或更合适吗 http github com ask carrot tree master http github com ask carrot tree master ht
python
django
MessageQueue
rabbitmq
AMQP
如何禁用 RabbitMQ 默认 tcp 监听端口 - 5672
我已经配置了RabbitMQrabbitmq config具有新端口号的文件 即带有 SSL 的 5671 现在我想禁用默认端口 即 5672 配置文件如下 rabbit ssl listeners 5671 ssl options cac
rabbitmq
在点网核心应用程序中使用 RabbitMQ 跳过 MassTransit 中的队列
我有三个项目 一个是Dot net core MVC 两个是API项目 MVC 正在调用一个 API 来获取用户详细信息 当询问用户详细信息时 我通过 MassTransit 向队列发送消息 我看到跳过队列 第三个项目中有消费者 即API项
ASPNETMVC
NetCore
rabbitmq
masstransit
与 RabbitMQ 相比,Amazon SQS 的性能较慢
我想在我的 Web 应用程序中集成消息队列中间层 我测试了 Rabbitmq 和 Amazon SQS 但发现 Amazon SQS 速度很慢 我在 Amazon SQS 中每秒收到 80 个请求 而在 Rabbitmq 中每秒收到 200
amazonec2
rabbitmq
amazonsqs
如何在 celery 内为每个用户生成队列?
因此 我尝试将 Web 请求中的阻塞内容移至后台任务并利用队列 我对消息传递和发布 订阅也很陌生 用户将数据推送到那里并进行处理 稍后用户会收到相关通知 我为此做了一个 celery 设置 发现它不能满足我为每个用户分配自己的任务的专用队列
django
Redis
rabbitmq
Celery
没有连接的 AMQP/RabbitMQ 通道什么时候会死亡?
我有一个简单的 RabbitMQ 测试程序 随机将消息排队 另一个读取它们 所有这些都使用 Spring AMQP 如果消费者死亡 例如 在没有机会关闭其连接或通道的情况下终止进程 则它尚未确认的任何消息似乎将永远保持未确认状态 我看过很多
Java
MessageQueue
rabbitmq
AMQP
springamqp
如何覆盖 MassTransit 默认交换和队列拓扑约定?
正如 在我关于SO的一个问题中 所指出的 为什么 MassTransit 中的简单配置会创建 2 个队列和 3 个交换机 https stackoverflow com questions 56064182 why a simple con
c
NetCore
rabbitmq
masstransit
组在 RabbitMQ 中接收消息,最好使用 Spring AMQP?
我正在从服务 S 接收消息 该服务将每个单独的属性更改作为单独的消息发布到实体 一个人为的例子是这样的实体 Person id 123 name Something address 如果姓名和地址在同一交易中更新 则 S 将发布两条消息 P
Java
Spring
rabbitmq
springintegration
springamqp
为什么 Celery 工作人员给出“OSError:套接字已关闭”
我的与rabbitMQ一起工作的celery工作人员在工作几分钟后不断给我一个套接字错误 见下文 我想知道问题的主要原因是什么 我认为这可能是防火墙 但是 禁用防火墙并没有解决问题 我正在 Windows 10 机器上工作 C Users
python3x
rabbitmq
Celery
worker
Broker
在 django 中使用 pika 的 Rabbitmq 监听器
我有一个 django 应用程序 我想使用来自rabbit mq 的消息 我希望监听器在启动 django 服务器时开始使用 我正在使用 pika 库连接到rabbitmq 提供一些代码示例确实会有帮助 首先 您需要在 django 项目开
django
rabbitmq
pika
Rails:如何从服务或队列中监听/拉取?
大多数 Rails 应用程序的工作方式都是等待来自客户端的请求 然后发挥其作用 但是 如果我想将 Rails 应用程序用作微服务架构的一部分 例如 并进行一些异步通信 服务 A 将事件发送到 Kafka 或 RabbitMQ 队列 而服务
rubyonrails
rabbitmq
ApacheKafka
microservices
在 Docker 中使用 RabbitMQ 删除容器
我尝试使用RabbitMQ启动Docker容器 结果下载了镜像 但容器没有启动 我在日志中收到以下消息 error RABBITMQ DEFAULT PASS is set but deprecated error RABBITMQ DEF
Docker
rabbitmq
在 RabbitMQ 主题交换中路由与模式不匹配的消息
两个队列绑定到具有以下路由键的主题交换 队列 A 与路由键模式匹配绑定 foo队列 B 与路由键模式匹配绑定 bar 我想向此交换添加第三个队列 该队列接收的消息都不是foo消息也不bar消息 如果我用一个绑定这个队列 路由密钥 我自然会得
rabbitmq
AMQP
MQ
bunny
使用spring-amqp和rabbitmq实现带退避的非阻塞重试
我正在寻找一种使用 spring amqp 和 Rabbit MQ 的退避策略来实现重试的好方法 但要求是侦听器不应被阻止 因此可以自由地处理其他消息 我在这里看到了类似的问题 但它不包括 后退 的解决方案 RabbitMQ 和 Sprin
rabbitmq
springamqp
springretry
发送消息到任意虚拟主机/与 RabbitMQ / Spring AMQP 交换
I use RabbitMQ and Spring AMQP发送消息 我有这个片段 rabbitTemplate convertAndSend exchange key object 当我对单个操作进行操作时 这有效VHOST 我必须从 1
Java
rabbitmq
MessageQueue
springamqp
为什么我已经安装了 RabbitMQ 却找不到“rabbitmq.config”文件?
我正在运行 Red Hat Enterprise Linux 7 2 我已经安装了 RabbitMQ 并systemctl status rabbitmq server shows rabbitmq server service LSB 启
rabbitmq
«
1
2
3
4
5
6
7
...40
»