1回答
1、购买CKafka时的数量是指什么数量？
2、CKafka文档说兼容Kafka接口，是否所有可以访问原生Kafka的第三方工具都可以访问CKafka？3、CKafka是否支持Kafka streaming接口？
浏览 225提问于2017-11-22
我有一个定价申请。它将定价请求发送到Azure Service Bus队列(可以是任何队列) "PricingRequestQueue“。有许多工作者负责收集这些数据，处理它们并将结果返回到PricingResponse队列。
我想在PricingResponse队列上创建一个观察值。我不需要任何过滤，但希望使用批处理接口(QueueClient.BeginReceiveBatch)读取消息。该队列具有预期的消息数，并且有一
浏览 5提问于2014-02-23得票数 4
我正试图理解Rabbitmq，以及如何只在某些情况下完成顺序消息处理。例如，如果我有两个队列。一种是定单定价，另一种是发出发票。有时，这些队列将获得消息并独立处理，但其他情况下，它们是依赖的，因为流程需要等待定价完成后才能发送发票。如果能做到这一点，又如何做到呢？我看过RPC并尽可能回答了答案，但我不确定。
浏览 0提问于2022-07-14得票数 -1
我正在尝试阅读Azure Service Bus queue技术规范和定价，但我不清楚2)有没有可能不根据消息大小来定价？看似如此，但我不敢相信。(我想每条消息发送大约10K - 100K数据。消息队列将由在多个实例中运行的并发相同的工作角色消耗。
提前进行Thx
浏览 1提问于2014-03-14得票数 14
回答已采纳
我有一个API，它将接收传入的有效负载并将其发布到队列中。当我试图通过Azure方法发布时，我会得到一个错误"SubCode=40000。我正在尝试使用队列方法，并希望在消息发布时创建队列。目前，服务总线使用的是一个基本的定价层，因为文档中说我可以在那个级别上处理队列。我不确定是否需要手动创建队列(我必须使用RabbitMq来实现这种方法，因为如果没有使用者，就不会创建队列)。如果没有指定任何内容，主题是否是默认方法？如何指定队列</
浏览 11提问于2020-05-28得票数 0
回答已采纳
1回答
如何按组处理来自SQS队列的消息
、、、、
我目前有一个SQS队列来触发lambda函数，但是SQS对在役消息有120 k的限制，这意味着只有120 k的消息可以由lambda使用者处理。大多数情况下都很好。但是假设我有客户机A和B，如果A向队列发送500 k，在此之后B只发送1条消息，B需要等待队列中的所有消息来处理。为每个客户端创建一个队列是没有意义的(至少不是手动的)。例如，我如何能够以循环的方式处理来自客户端的消息，让每个人都有相同的时间来处理他们的任务？
我一直在研究
浏览 2提问于2022-03-11得票数 0
回答已采纳
快速处理消息队列的策略和模式是什么？
我有一个Lambda函数，它每隔x分钟按调度调用一次，以处理队列中的许多消息。我可以缩短间隔，但是很多时候不会有任何消息需要处理，而且由于Lambda是按请求定价的，这将是成本效率低下的。所以我想找一些其他方法来实现这个目标
浏览 0提问于2018-07-07得票数 0
回答已采纳
1回答
是否有方法授权Azure服务总线队列的某些消息发送者只能发送特定的消息？例如，发送方1可以发送消息类型123，但是发送方2可以发送消息类型456。当使用1试图发送消息123时，它们将被拒绝，或者消息不会被处理。
我一直在研究SAS授权类型，但我不太确定如何在从队列中提取消息的服务器上使用该授权类型。
浏览 1提问于2015-08-30得票数 0
回答已采纳
我看到SQS FIFO队列最近获得了Lambda事件映射- https://aws.amazon.com/blogs/compute/new-for-aws-lambda-sqs-fifo-as-an-event-source消息处理被描述为通过以下规则进行- 1) Return the oldest message where no other message with the same MessageGroupId is. 1)和2)听起来很棒-每个Lambda请求批次只包含一个MessageGroupI
浏览 32提问于2019-12-25得票数 1
目前，我使用Azure use作业来处理Azure队列中的请求。在一天内，一个网络作业可以处理来自队列的多达5,000条消息。每条消息最多处理20秒。网络作业一直在侦听队列中的新消息。到达时，选择消息并处理它。我主要关心的是工作负荷效应。如果队列触发函数仍在20秒内处理一条消息，另外50条
浏览 1提问于2018-10-22得票数 1
回答已采纳
在腾讯云服务器上生产者给Ckafka服务器发送消息报错：org.apache.kafka.common.errors.TimeoutException: Failed to update metadata
浏览 5369提问于2018-10-10
3回答
我有使用队列触发的WebJobs处理后台任务的经验；但是，此作业需要的资源比我的Web App Service计划需要的资源多，我不想在运行Web App的同时运行此计算进程。我希望我可以为每个请求编写一个队列消息，然后让某个东西每晚检查该队列，看看它是否有任何消息。如果是，则创建/启动一个新的Worker角色实例，该实例具有足够的能力/内存来处理作业，处理队列消息，然后关闭/并解除分配worker，以防止正在进行的费用。我找不出在启动Wo
浏览 4提问于2017-02-22得票数 1
我正在集成MWS Amazon。对于进口产品，我需要一个重要的领域，如卖方的产品是否是买方胜利者。我需要在我们的数据库中设置标志。
浏览 11提问于2017-05-04得票数 1
回答已采纳
在每个主题上，每秒有1000种不同的语言，其中每条消息的大小都是1KB。另一方面，我有一个订阅者，它只订阅一个主题，并且应用了过滤器，所以它每秒只接收10条消息，而不是1000条。5* 1000 msg/s x 60*60*24*30 * 1KB = 12 96万条消息* 1KB，用于一个月内的五个主题。在订阅方，我们有1* 10 msg/s x60*60*24*30* 1KB = 25 920 000条消息* 1KB。
那么，我是要为A还是B收费呢？A: 12 960 000条消息*
浏览 5提问于2012-04-10得票数 2
1回答
场景:一个将通过WSDL从NetSuite获取所有供应商记录的Azure WebJob。NetSuite有一个异步进程，基本上可以在服务器上运行你想要的任何东西，它会返回一个JobId，允许你检查服务器上的进程。 private static bool ChkProcess(VendorsService vendorService, strin
浏览 0提问于2019-04-15得票数 0
3回答
我的第一个想法是使用队列存储，并为30天的时间限制设置可见性超时，但这似乎会随着时间的推移快速增加队列，特别是如果消息不应该运行30天；更不用说排序问题了。我也在研究任务调度程序，但会话定价的变化不是一个反复出现的概念，而是更随机的。队列是一种很好的方法，还是有更好、更有效的方法来实现这一点？
浏览 1提问于2015-06-02得票数 6
我有一个IIS服务器托管的web应用程序(名为“后端”)，需要查询另一个web应用程序(名称“定价”)也由IIS服务器托管。因此，当后台需要查询Princing时，它会请求其控制台发布队列中的消息，然后附加到Pricing的控制台获取该消息并将其提供给Pricing (使用Invoke<>方法)。总结: Backend -> Console -> RabbitMQ <-控制台<-定价
我有2个价格从他们的控制台从RabbitMQ队列中获取消息<
浏览 3提问于2020-03-02得票数 0
2回答
我最初的想法是使用API网关，将这些请求放到一个SQS队列中，然后分批从这个队列中读取。
但是，我希望ec2实例能够读取这些批次，因为用于处理webhooks的代码在我的应用程序中被重用。
浏览 0提问于2018-10-16得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
