请帮助为以下用例选择MQ应用程序/系统/方法:检查特定用户的传入消息->阅读消息(如果可用)->从队列中删除，理想情况下，留在AWS中。上下文:社交网络应用，用户接收消息，即我需要通过收件人ID识别收到的邮件。该应用每30秒对新消息进行一次长轮询。邮件大小为根据目前的估计，我每月总共需要检查1亿多条消息(但是，消息少得多，这些只是检查)。虽然用户确认消息选择“确定”或“忽略”，但不确定是否需要来自MQ系统的ACK支持。我在AWS。最初想到SQS，但我读得越多，它看起来就越不适合-无法以按收件人过滤的方式设置消息收件人ID等，但也许我错了。我还考虑过的选项之一是只使用DynamoDB的“

我想使用redis来存储不同用户的个人资料浏览量。我没有在每个页面View上更新表(将计数增加1)，而是考虑在列表或redis上存储和增加该配置文件的(View)计数。然后定期从列出并更新表格。因此可以减少对数据库的查询次数。列表或任何其他数据结构会更好用吗？还有其他更好的方法吗？ 最佳答案 在这种情况下，List不太适合，因为它的成员是不可变的并且您希望更新计数。相反，考虑使用哈希，其中每个字段代表一个配置文件，值是该页面的计数器。每个页面View都会触发一个HINCRBY到相关字段的值。您可以定期读取该哈希的内容，将其删除并将增

我正在学习如何使用senecajs从redis获取数据，但seneca提供了多个插件来连接到redis。可用的插件是标题中提到的插件。我应该使用哪个来从Redis中获取几个键？两者有什么区别？ 最佳答案 seneca-redis-pubsub-transport和seneca-redis-queue-transport两者都用于使用Redis在服务之间传输消息。seneca-redis-pubsub-transport是一种广播传输。所有订阅的服务都将收到所有消息。seneca-redis-queue-transport另一方面是队

我有不同的celery队列，在某个时候我希望工作人员停止从我的队列中消费celery_app.control.cancel_consumer(consumer_queue)一段时间后我希望能够恢复消费者，我用下一个命令来做到这一点celery.control.add_consumer(consumer_queue,routing_key=consumer_queue,destination=['worker-name'],)此时我预计worker-name将从consumer_queue获取任务，我的自定义路由器通过routing_key重定向。但是我从celery检查中得到了这个输出

我目前使用数据库作为我的队列驱动程序，我已经在Windows10PC上安装了Laravel5.4。为了处理队列，我一直在使用phpartisanqueue:work，这在开发阶段完全没问题。现在，该项目已完全准备就绪，需要部署在Linux服务器(专用)上我不确定如何避免在终端上运行命令phpartisanqueue:work以处理邮件作业？我已经在共享主机中部署过一次并且我使用了cron作业，但是现在我有专用服务器我想我应该可以使用其他东西来运行作业，我也在考虑使用Redis作为队列驱动程序而不是数据库作为队列驱动我需要一些关于什么是最好的建议。以及如何避免在专用服务器上使用phpar

我正在使用redis在不同的应用程序之间发送和接收数据。但是，我发现当一个应用程序push数以千计的数据到一个队列时，另一个实现pop的应用程序有不完整的数据!为了确定问题-我在push和pop处添加了计数器，发现pop计数器比pushed少，我也不知道当pop完成执行时，在同一队列中看不到任何待处理的消息。我正在尝试挖掘数据丢失的位置。我应该尝试哪些方法？redis-cli中是否有任何命令可以显示给定队列的推送和弹出计数 最佳答案 您可以从redis-cli使用MONITOR命令。将输出通过管道传输到一个文件，然后您应该可以很容易

我想通过scrapy框架和scrapy-redislib做一个有针对性的分布式爬虫。这里我需要两个队列，一个叫做prior_queue，另一个是urls_queue。两个队列都根据它们的分数维护排序的请求。爬虫总是从prior_queue中取出第一个请求，直到prior_queue为空，然后将一些请求从urls_queue移到prior_queue。所有产生的请求都被推送到urls_queue。有了这样的要求，谁能给我一些解决方案或想法如何实现它？我应该修改哪些scrapy模块以满足我的要求？ 最佳答案 Scrapy有一个队列。您可

所以这或多或少是一个理论问题。假设我们有一个由3个节点组成的多节点Swarm。现在我们已经安装了一个使用Celery和Redis作为消息代理的Python服务。所以基本上还有一个3节点副本redis服务作为应用程序的一部分。现在，由于此Redis服务充当消息代理，如果我们仅使用服务名称在我的Python应用程序中进行DNS解析，那么dockerswarm或我的应用程序如何知道哪个redis节点将执行我放置的任务队列？我的意思是路由网格只会在任何一个具有该服务的节点上引导特定服务的流量。现在我的Python应用程序异步启动了一个任务并将其放入redis队列中。所以一旦完成，我希望我的应用

所以我正在尝试将Web请求中的阻塞内容作为后台任务并利用队列。我也是消息传递和发布/订阅的新手。用户将数据推送到那里并进行处理，稍后会通知用户。我为此做了一个celery设置，发现它不能满足我的用例，即为每个用户设置私有(private)队列来完成他们自己的任务。我尝试指定缺少队列的创建和工作人员产卵期间(发送队列名称以逗号分隔)，并将它们列在队列设置中，如之前在互联网上对“使用celery创建动态队列”的回答中所述。它会创建队列，但当我在设置和命令行中指定的队列名称与指定名称不同时，它不会创建队列。解决方案是使用不满足用例的队列名称生成更多工作人员，因为将有数百万个数据处理请求。我发

我无法使用Celery中的inspect()函数来查看队列中的事件项和保留项。它不会返回类似{u'celery@mymachine':[]}的内容，而是始终返回None。这是在我将我的Docker从使用python:3.6-alpine更改为python:3.6之后开始的，但现在，即使在我恢复到alpine之后，我仍然收到这种行为。我已经尝试了这里建议的所有内容:CeleryscheduledlistreturnsNone但它们似乎都不起作用。我在下面包含了一个显示我的问题的最小示例如果有人知道是什么原因造成的，我将不胜感激Docker文件:FROMpython:3.6-alpineE