1回答
1、购买CKafka时的数量是指什么数量？
2、CKafka文档说兼容Kafka接口，是否所有可以访问原生Kafka的第三方工具都可以访问CKafka？3、CKafka是否支持Kafka streaming接口？
浏览 227提问于2017-11-22
有一种情况是，脚本将所有未使用的卷is写入AWS队列，一段时间后，我们需要接收所有带有卷is的消息，并删除这些卷。是否有一种使用python库来实现这一目标的方法？使用boto库接收AWS SQS队列中的所有消息，直到队列为空
浏览 11提问于2022-11-25得票数 -1
回答已采纳
所以我有一个sqs队列，它接收生产者的消息。每条消息可以属于不同的所有者。我想为系统中的每个用户创建一个队列，但这意味着每次进行轮询时都要从每个用户那里读取，这是非常昂贵的。
浏览 1提问于2018-03-02得票数 1
回答已采纳
2回答
在我的拓扑中，在处理流时，我希望将一些消息的处理推迟到将来的某个时间点。这样做有哪些合理的选择？
Storm是否有一些API来延迟我忽略的消息？ZeroMQ是否提供了Storm (如果修改)可以利用的延迟消息传递API？
浏览 2提问于2013-05-16得票数 5
回答已采纳
1回答
我们有一个基于JMS的消息传递应用程序，每天处理大约200万条消息。到目前为止考虑的两个设计选项是：
a)将所有消息转发到消息驱动bean (MDB)将在其上处理它们的第二个队列-这使第一个应用程序完全不知道是否需要此功能b)在原始应用程序中，仅过滤出60%的卷</
浏览 0提问于2012-07-27得票数 0
回答已采纳
1回答
我试图了解SQS触发器在从队列中轮询消息时是如何工作的。我试图确保在1秒内处理的消息不超过3条。Idea
我的想法是将触发器BatchSize设置为3，并将队列的ReceiveMessageWaitTimeSeconds设置为1秒。我想得对吗？如果我将Lambda并发限制设置为确保一次只处理一批消息的限制。如果我的lambda运行了一秒钟，那么下一批消息至少会在一秒钟后被处理。这里的缺点是长轮询自动缩放队列中基于消息卷的异步轮
浏览 6提问于2021-10-08得票数 1
3回答
我有一个队列，队列中全天都有高优先级的JMS消息，我想让它们快速离开。该队列也被周期性地以大批量的低优先级消息加载。在繁忙的日子里，我看到的问题是，队列前面总是有足够多的高优先级消息，在该卷下降之前，不会选择任何低优先级的消息。通常他们会坐在队列上直到半夜。我的直觉是实现某种老化算法，提高队列中已存在很长时间的消息的优先级，但当然，这就是中间件应该为我做的事情。读取队列</
浏览 23提问于2014-12-12得票数 0
我在这里使用的是rabbitmq舵图：
我希望将消息和队列存储在minikube之外，这样每次运行minikube时，我都可以从那里继续。但是，我在文档中看不到如何添加卷或持久卷以指向我的主机。
浏览 1提问于2020-04-11得票数 0
如果分区太长(卷太高)，最终消息会丢失吗？
另外，如果系统在分区期间崩溃，那么卡夫卡队列中的所有消息是否都丢失了？
浏览 2提问于2014-07-31得票数 3
回答已采纳
我想把客户端从REST中获取消息的系统放在一起，但是生产者能够使用消息队列的语义:例如消息排序、目标邮箱等等。
我想每个客户端可以有一个消息队列。当客户端连接到N个无状态When服务器/REST端点中的一个以获取新消息时，任何新消息都会从消息队列上的客户端邮箱中退出队列，打包并发送到客户端，作为对GET的响应。似乎每个REST请求都会建立到消息队列的新连
浏览 0提问于2015-11-02得票数 2
5回答
重异步处理
、、
将这些数字加载到消息队列中(我目前使用MSMQ )。将命令行应用程序中的消息排出队列，并通过http将请求发送到某些服务，比如每个电话号码3次，最后登录到数据库。
问题是:它仍然需要很长时间才能完成。MSMQ对它可以接收的消息的大小也有限制，现在我必须创建多个消息队列。我需要大量的容错能力，但由于性能原因，我不敢让消息队列具有事务性。我正在考虑将消息队列(目前是一个私有队列)发布到
浏览 3提问于2010-06-29得票数 5
我有一个用例，其中我有两个SQS队列，每个队列都收到消息。但条件是，如果我在第一个队列中获得消息，我将停止从第二个队列读取消息，并优先处理第一个队列消息。我可以只用一个SQS计票器来处理这个问题吗？问题陈述:我经常在第一个队列中得到消息，但它们是重要的消息。但我不断地在第二个队列中获取消息。因此，如果轮询器正在处理第二个队列的<
浏览 8提问于2020-01-29得票数 0
我们已经有了IBM队列管理器。我们还需要在EC2中部署一个吗？我们是否需要将它们部署到应用程序将运行的EC2框上？
我是IBM的新手，尽管我对RabbitMQ有一些经验。他们曾多次告诉我，我们需要在盒子上运行一个队列管理器，然后它可以转发给其他队列管理器，但是在一个带有临时磁盘的云机器上，这对我来说没有任何意义--它没有增加任何可靠性。我们可以在带有EBS卷的EC2机器上部署一个队列管理器，这样做会更有意义，并让我们的应用程序对此进行讨论。但这是否真的比直接在我们自己的楼宇内与现有的队列
浏览 0提问于2016-07-25得票数 2
他们是否为电子邮件提供了队列机制？我在他们的API文档中找不到这一点，他们的技术服务只对购买了该帐户的用户可用。
有没有人能找到解决这个问题的办法？
浏览 0提问于2016-01-03得票数 1
在卷管理器的帮助下，我将这4个LUN转换成4个不同的卷。
现在的问题是，将tempdb移到单独的卷中会有什么不同，还是在性能方面将它们与其他Server文件保持在一起还可以呢？
浏览 0提问于2020-06-09得票数 5
回答已采纳
我有多个Spring Boot应用程序，使用来自RabbitMQ队列的消息。所有消费者都使用MqttDefaultFilePersistence。将持久化数据写入到持久化卷上的目录/tmp/mqtt，配额为100M。正如我在RabbitMQ管理控制台中看到的那样，队列中的消息正在填满。RabbitMQ日志中没有错误消息。在这种情况下，唯一有效的解决方案是在RabbitMQ管理控制台中删除订阅队列，然后重新启动使用者应用程序。也许有人遇到了类似的问题？
浏览 1提问于2017-11-24得票数 0
我们遇到了一些延迟问题，并尝试用一堆编年史队列替换Kafka主题。当在本地开发人员机器上运行时，结果令人惊叹，我们最昂贵的工作流之一是处理速度快了10到30倍。我们创建了一个EFS卷，并将其挂载到每个docker容器上。我们验证了可以从每个微服务访问该卷，并授予了正确的读写权限。现在问题来了: MS1接收到一条消息(API调用)，进行一些处理，并在历史记录队列中发出一个事件。我们可以在EFS文件系统上看到历史记录队列文件被触动。MS2应该使用该事件并做一些进一步的处理。最终，重新启动MS
浏览 22提问于2021-08-19得票数 0
回答已采纳
我有一套3个AWS lambda函数(卷备份监控函数)。我已经创建了3个函数，这样每个函数将只有1个循环，这样执行时间(和账单)更少。每个lambda函数都会调用SQS中的下一个lambda函数。我还有一个lambda函数，它从队列中提取消息并执行请求的lambda函数。
我的问题是关于日程安排。我可以安排Lambda1以期望的频率运行(比如每10分钟运行一次)。如何调度读取队列的lambda？我可以计划每n分钟运行一次，但是一旦队列为空，就不需要在一天结束之前执行它。我能从lambda函数中以某种方式禁
浏览 2提问于2017-12-11得票数 0
2回答
它有7个队列，大部分时间都是空的，也就是说，一旦消息被放入队列，它就会在接下来的5-10秒内被消费。然而，消息量是相当大的(每天几千条消息)。它们占用了宝贵的空间(KahaDB托管在固态硬盘卷上)，而且似乎是多余的，因为在我看来，日志日志保存的是旧的(即出列的)消息。
所以问题是:如何去除日志文件？我只想让KahaDB只存储挂起的消息。
浏览 2提问于2011-05-30得票数 7
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
