腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
可以列出每个
队列
在SQS中拥有的
消息
吗?
node.js
、
amazon-web-services
、
typescript
、
amazon-sqs
、
nestjs
我正在尝试使用
队列
的aqs sqs,并能够发送后的问题,以及CRUD。现在,使用下面提到的代码,我列出了我拥有的
队列
数量,现在我想要每个
队列
在AWS SQS中拥有的
消息
数量。const params = {}; return !
err
?resolve({data}) : reject (new HttpException(
err
, 500
浏览 4
提问于2018-07-23
得票数 0
1
回答
如何验证publisher的确认行为
go
、
rabbitmq
、
amqp
我正在编写一个包含publisher确认的go程序,并且我希望验证
消息
何时可以传递/不被传递给代理时的行为。connection,
err
:= amqp.Dial("amqp://localhost") panic(
err
)<em
浏览 3
提问于2015-03-05
得票数 3
1
回答
有Node库的Azure服务总线
队列
的最大吞吐量?
node.js
、
azure
、
queue
使用Azure NodeJS库,我无法以每秒5或6条
消息
的速度从Azure服务总线
队列
接收
消息
。这比官方文件建议的要慢几个数量级。我使用的是关闭分区的
队列
(如这里所建议的,),在ReceiveAndDelete模式下读取。实际上,我只是重复调用.receiveQueueMessage()。基于这个问题(),似乎其他人在使用NodeJS时每秒也会看到5/6的
消息
。这是个很难的限制吗?有没有已知的解决办法或优化?
浏览 2
提问于2015-12-05
得票数 0
回答已采纳
2
回答
MQ何时抛出'MQJMS1022:未能重定向
消息
‘?
java
、
jms
、
ibm-mq
、
mq
MQ何时抛出'MQJMS1022:未能重定向
消息
‘? 我们的应用程序(运行在JDK1.5上)连接到MQ7.5。从MQ读取
消息
时,将引发以下异常。
浏览 1
提问于2016-02-04
得票数 0
回答已采纳
1
回答
IBM MQ cmit和具有同步点的回滚
javascript
、
node.js
、
ibm-mq
Infra-Overview:我观察到,有时
消息
流很大,在将其发送到目标主机之前,我们的吊舱会失败并重新启动,这样我们就会丢失所有的
消息
,因为我们遵循的是从中读取和删除的方法。预期解决方案:我们在IBM中有一个unit of work的概念,但是由于我们不能期待读取和处理方面的延迟,所
浏览 1
提问于2020-11-04
得票数 1
回答已采纳
1
回答
如何以编程方式向Go中的SNS主题订阅SQS
队列
?
aws-sdk-go
:= makeTopicAndQueue();
err
!(&sns.CreateTopicInput{Name: aws.String(topicName)}) if
err
!QueueUrl, }) if
err</e
浏览 1
提问于2019-01-15
得票数 2
回答已采纳
2
回答
如何使用Azure云函数将所有Azure存储
队列
消息
批处理为Blob?
azure
、
azure-blob-storage
、
azure-functions
、
azure-storage-queues
我要读取Azure
队列
存储的所有
消息
并将它们写入Blob。理想情况下,我希望读取10000个或更多的批次,并将它们写入Blob。我正在使用Azure Cloud Functions,其中
队列
存储绑定用于输入,Blob存储绑定用于输出,但我找不到使我能够读取多条
消息
的API或配置选项。有人知道这样的API吗?
浏览 10
提问于2018-02-19
得票数 4
回答已采纳
1
回答
Golang RabbitMQ
go
、
rabbitmq
、
message-queue
我学习了本教程的示例,但是它只读取了一次
队列
中的所有
消息
,如何从
队列
中只读取一条
消息
?感激不尽!messages,
err
:= channelRabbitMQ.Consume( "",// no local nil,
浏览 3
提问于2022-03-18
得票数 0
2
回答
如何使用WebJobs处理存储
队列
javascript
、
node.js
、
azure
、
azure-webjobs
、
azure-notificationhub
这里是这样的情况,我使用Azure的存储
队列
,我使用来自我的webapps的webjob来处理存储
队列
。
队列
中的
消息
将通过通知中心发送给每个特定用户。(推送通知) 因此,
队列
将具有5万或更多
队列
消息
的大小。所有这些
消息
都用来逐个将
消息
推送给用户。但是,我试图通过调度2分钟间隔来使用WebJob来处理
队列
。对于我的脚本,它将在循环中运行5万或更多的用户
消息
。然后,它将通过Azure nodejs包发送
浏览 3
提问于2016-01-26
得票数 0
回答已采纳
2
回答
当我试图从两个不同的终端选项卡轮询相同的Amazon时,我不会在这两个选项卡中得到相同的
消息
。
amazon-web-services
、
message-queue
、
amazon-sqs
、
amazon-sns
、
long-polling
我有一个Amazon
队列
订阅了这个主题。我使用sqs-consumer API来长时间轮询SQS
队列
。) => {}); console.error(
err
.message从单个终端运行这段node sqs_client.js文件时
浏览 0
提问于2019-08-12
得票数 3
回答已采纳
2
回答
Azure服务总线
队列
侦听器- NodeJs
node.js
、
azure
、
azureservicebus
我已经研究过了,但是找不到如何在Nodejs中创建Azure服务总线
队列
侦听器。到目前为止,我发现的唯一方法是使用用于Node.js的Microsoft,通过
消息
向
队列
请求
消息
,这是不符合成本效益的。任何帮助都将不胜感激。sbService.receiveQueueMessage(queueName, { isPeekLock: true }, function(
err
, lockedMessage) { if (
err
=
浏览 3
提问于2017-09-28
得票数 0
回答已采纳
2
回答
如何使用节点库从rabbitmq中删除所有
消息
?
node.js
、
rabbitmq
在开始推送数据之前,我希望删除兔子mq
队列
中的所有
消息
。如何才能做到这一点?我正在使用
浏览 9
提问于2016-03-31
得票数 3
回答已采纳
1
回答
如何在预定时间内触发Api调用
api
、
go
、
microservices
、
twitter-api-v2
我正在构建一个简单的平台,允许Twitter用户按照他们自己选择的时间安排向他们的Twitter帐户发帖。例如,某个人可能想在午夜12点整向他/她的Twitter账户发帖子,但是平台允许他们在下午4:00之前创建帖子,并在预定的时间点自动发布到他们的时间线上。我对如何实现这一点感到困惑,因为负责此操作的Api端点必须手动调用才能发生此事件,我想使用cron作业每分钟运行一次,检查所有预定的帖子,如果是时候创建post,则调用端点,但我觉得这很麻烦,而且容易出错。请问有更多的程序方式来实现这一点吗?
浏览 13
提问于2022-08-01
得票数 1
1
回答
AWS SQS 1
队列
2订阅者
javascript
、
node.js
、
amazon-sqs
我正在尝试使用具有两个长轮询nodeJS实例的单个SQS
队列
。我面临的问题是,当我将一条新
消息
放入
队列
时,两个实例都会立即拉出相同的
消息
。有没有办法防止这种行为?我的目标是最终拥有一个NodeJS处理群,其中每个实例将从
队列
中提取唯一的
消息
并执行处理。WaitTimeSeconds: 20, }; sqs.receiveMessage(params, (
err
, data)
浏览 0
提问于2018-06-11
得票数 0
1
回答
消息
仍然在nats中限制
队列
,一个又一个ack和术语发送到Go
go
、
nats.io
我尝试为NATS限制
队列
编写订阅服务器:if
err
!= nil {} if
err
!msg.Term() msg.Nak()} 此代码的目标是
浏览 21
提问于2022-09-13
得票数 2
回答已采纳
3
回答
RabbitMQ:由exchange添加的
消息
,没有任何现有绑定。
rabbitmq
、
amqp
我正在向没有绑定到任何
队列
的主题交换发送一条
消息
。只是一个空白的交换。该通道被创建为确认通道,每次发送
消息
时都会调用我的确认回调。奇怪的是,我收到的每一条信息都是非法的。我如何知道
消息
是被路由到
队列
,还是被交换所丢弃?var amqp = require('amqplib/callback_api'); amqp.connect('amqp://host
浏览 1
提问于2016-02-26
得票数 6
1
回答
当服务器端出现错误时,WebSphere API总是提供MQ原因代码吗?
java
、
ibm-mq
当试图从
队列
中提取
消息
时,我得到以下错误: Original thrown object message: com.ibm.msg.client.wmq.v6.jms.internal.ConfigEnvironment
浏览 4
提问于2016-02-19
得票数 1
1
回答
PullWait在Go酒吧子图书馆的行为?
go
、
google-cloud-platform
、
google-cloud-pubsub
我的代码测试PullWait函数的行为,根据,该函数执行以下操作: msgs,
err
:= pubsub.PullWait(subCtx, subscriptionName, 50) if
err
!:= pubsub.Ack(ct
浏览 1
提问于2015-11-04
得票数 4
1
回答
读取iotHub云到设备
队列
中的旧
消息
c#
、
node.js
、
azure-iot-hub
我有一个node.js代码(设备端),用于侦听azure IotHub设备
队列
上的
消息
。 如何更改设备代码以侦听旧
消息
?
浏览 2
提问于2018-04-11
得票数 0
1
回答
使用AMQP/RabbitMQ向独占
队列
发送
消息
node.js
、
rabbitmq
、
amqp
要启动一个操作,我想要发送一条
消息
到一个由机器ID命名的
队列
,例如"12345“。ch.assertQueue(machineID, {exclusive: true, durable: false}, function (
err
,
浏览 0
提问于2017-10-16
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
java实现消息队列以及延迟消息(队列DelayQueue)
消息队列-架构为什么需要用消息队列
消息队列-延时消息实现
为什么需要消息队列,及使用消息队列的好处?
全面理解Handler-1:理解消息队列,手写消息队列
热门
标签
更多标签
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
活动推荐
运营活动
广告
关闭
领券