使用celery，是否可以使用RabbitMQ侦听新消息并调度worker来处理它？celery 的很多功能是将其用作具有代理(比如RabbitMQ)的任务生产者，在该代理中执行任务并通过代理交付任务。我希望使用来自代理的消息(由其他服务生成)，并使用celery处理这些消息。
浏览 8提问于2018-01-30得票数 1
1回答
我们在heroku上安装了一个应用程序，它使用celery来运行后台作业。芹菜应用程序使用RabbitMQ作为代理。我们使用heroku的AMQP附加组件作为RabbitMQ消息代理。这个附加组件指定了两个单独的url，一个为生产者优化，另一个为消费者优化。此外，根据RabbitMQ文档，建议对生产者和消费者<
浏览 3提问于2013-11-07得票数 5
我正试图从一个芹菜生产者那里向一个芹菜消费者发送一个信息，并在生产者中获得结果。有一个生产者和一个消费者，但两个兔子的(作为经纪人)和一个红色(结果)在两者之间。我可以看到，在rabbitmq管理web接口中，我的消息正在由rabbitmq交换接收，但它没有显示在相应的rabbitmq队列中。另外，ZipUp任务刚开始时发送的日志消息</
浏览 3提问于2016-07-28得票数 0
我正在使用Django-kombu和芹菜，但在相当多的地方读到它还没有准备好生产。有没有人能给我更清晰的描述，在处理芹菜+ Django时，生产堆栈是什么样子的？
浏览 1提问于2013-01-06得票数 3
我有一个现有的RabbitMQ部署，有几个Java应用程序在各种渠道上使用将日志消息作为string JSON对象发送出去。我想使用Celery来消费这些消息，并将它们写到不同的地方(例如DB、Hadoop等)。我可以看到，Celery被设计为既是RabbitMQ消息的生产者，又是are消息的消费者，因为它试图隐藏传递这些<em
浏览 0提问于2012-10-02得票数 10
回答已采纳
是否可以使用activemq artemis定义目标别名。我们需要的是能够为同一目的地使用两个不同的名称，并且消费者/生产者可以决定使用这两个名称中的任何一个。我们过去常常使用ActiveMQ classic，使用一个自定义插件来改变消息的目的地、生产者和消
浏览 20提问于2021-09-10得票数 0
回答已采纳
我相信三种类型的确认作为生产者属性仅限于领导者和生产者，当消费者通过kafka broker从存储/队列中消费一条消息时，我希望生产者收到一个具体的消息。另外，如果我在生产者的‘ack’属性上弄错了，默认是'-1‘，它确认是否所有的副本都收到/存储了消息，但是它与消费者有任何关系吗?或者当消费者提交
浏览 1提问于2021-02-09得票数 0
回答已采纳
1回答
芹菜不停工
、、
我正在创建一个分布式网络爬虫，可以同时抓取多个社交媒体。该系统旨在根据不同社交媒体的当前发帖率将可用资源分配给不同的社交媒体。我决定通过Celery、Flask、rabbitMQ和Kubernetes作为资源管理器来实现这个项目。如何告诉celery在rabbitMQ中保留固定数量的任务？我需要一个系统来管理自由的工人，并立即分配任务给他们。我想要的系统应该检查空闲和忙碌
浏览 0提问于2021-06-03得票数 0
我们有一个以两种方式使用芹菜实例的应用程序:实例的.task属性用作任务装饰器，当我们调用celery worker的实例时，我们将实例作为-A (-app)参数传递。这个工作流对生产和消费都使用相同的芹菜实例，而且它已经起作用了，但是我们对生产者(任务)和消费者(芹菜工人)都使用相同
浏览 2提问于2013-10-01得票数 5
我们有一个生产者服务，它将消息发布到主题，我们有3个消费者从主题中读取该消息的实例。生产者只需要在所有消费者处理并回复另一个应答队列中的成功消息时才需要做进一步的处理(更新DB)。即使其中一个使用者服务由于某些异常或应答队列中的任何失败消息而失败，生产者也不应该为该发布请求执行update D
浏览 1提问于2018-10-10得票数 0
我们在课堂上学习了生产者/消费者模式，但仅以一个生产者和一个消费者为例。在我们的家庭作业中，我们被要求做以下工作：
编写了一个生成随机字符串的程序，然后使用生产者/消费者模式按字母顺序对它们进行排序。创建1000个字符串并使用大小为100的有界队列。使用100名生产者<em
浏览 0提问于2020-04-18得票数 0
回答已采纳
ActiveMQ Apollo是否会自动在连接的客户端协议之间转换消息？我试图做的是让一个生产者使用一种协议(STOMP或任何其他协议)，但让消费者随心所欲地选择他们的协议，这样他们就可以是MQTT、STOMP、AMQP、OpenWire等。Apollo可以根据消费者实现的协议转换消息吗？如果不是，有没有不同的方法，而<
浏览 1提问于2013-06-18得票数 4
回答已采纳
1回答
假设我有以下组件：
我知道这在Java这样的可变语言中很容易实现。我还知道，可以通过允许与接口(如所描述的 )进行部分更改来解决这一问题。但是
浏览 0提问于2015-06-18得票数 4
我有一个生产者线程和消费者线程，其中生产者运行得比消费者快我需要从生产者传输数据并在消费者上处理它，生产者将每秒提供1000个元素的数组，消费者应该等到它有10组数组并处理它(消费者每10秒运行一次)我可以看到，我们可以修改POSIX消息队列，以输入包含1000个元素的双精度数组
POXIS消息</em
浏览 2提问于2020-07-26得票数 0
1回答
目前，我们有一组30名生产者和30名消费者正在使用来自单个ActiveMQ实例的消息。所有生产者都会写到25个队列，所有消费者都可以从队列中消费。到目前为止，没有消息路由或故障转移。我们希望使其水平可伸缩，而不需要对生产者和消费者进行任何代码更改。
我们的一个想法是使
浏览 4提问于2014-01-16得票数 2
回答已采纳
场景1:生产者->队列->消费者生产者-> Queue1 ->骆驼(再排序) ->Queue2 ->消费者我们可以在不使用骆驼Queue2的情况下完成场景2吗？我希望
浏览 2提问于2019-05-22得票数 0
3回答
我能够在我的Kafka代理和客户端中设置SSL，并且我还能够看到，当我们使用9093端口(即SSL端口)生成消息时，消息由消费者使用。
我尝试通过9093端口发送消息，消息从生产者发送到消费者。我的意思是，我如何才能证明9092不是SSL，而9093是SSL和安全的？
浏览 0提问于2016-03-03得票数 9
3回答
我了解到，在实现生产者消费者模式时，我们可以使用BlockingQueue而不是经典的wait()和notify()。我的问题是，哪个实施更有效？在一篇关于阻塞队列的文章中，有人写道--“您不需要使用wait和notify在生产者和消费者之间进行通信”
阅读更多：“。这种简单性是以牺牲效率为代价的</e
浏览 3提问于2013-11-25得票数 2
回答已采纳
1回答
最近，我们与卡夫卡的消费者和制片人出现了一些性能问题。我们在scala中使用。什么是好的做法wrt打开和关闭消费者和生产者对象？我相信这是一个非常开放的问题，正确的答案永远是depends，但我正在努力思考这个问题。当我们完成产生<e
浏览 1提问于2018-11-15得票数 6
回答已采纳
1回答
我正在寻找一个解决方案，其中有多个主题创建在Kafka服务器上，并基于另一个应用程序，它将尝试发布来自任何生产者的消息，但我们不知道如何启动基于生产者的相应消费者。我们目前已经实现的解决方案是，我们已经启动了所有的消费者，所有人都会倾听，当任何生产者发布消息时，它将被适当的消费者接收，这不是实现它的</
浏览 16提问于2020-12-28得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
云直播
腾讯会议活动推荐
腾讯云开发者
