Tag: azureservicebus

如何使用Azure函数绑定发送预定的服务总线队列消息？: 我有一个写在node.js中的Azure函数，它使用输出绑定成功地将消息发送到Azure服务总线队列。我怎样才能发送一个预定的消息到同一个队列仍然使用绑定语法？如果可能的话，我宁愿这样做，而不安装node.js sdk。绑定文档没有提到预定的消息。然而，有趣的是，这个评论已经在函数github问题库上做了几次：至less使用C＃＆Node.js（以及为什么不在F＃中）Service Bus队列输出已经支持这个，例如，如果创build并放置多个消息，例如给IAsyncCollector或创buildBrokeredMessage。在您的传出信息中，您可以控制预定的排队时间： outgoingMessage.ScheduledEnqueueTimeUtc = DateTimeOffset.UtcNow.AddSeconds(10) 无论如何，这是我目前的代码，工作正常，立即传递消息： function.json { "disabled": false, "bindings": [ { "authLevel": "function", "type": "httpTrigger", "direction": "in", "name": "req" }, { "type": "http", "direction": "out", "name": "res" }, { "name" : "queueOutput", "queueName" : "scheduler", "connection" : "AZURE_SERVICEBUS_CONNECTION_STRING", "type" : "serviceBus", "direction" : "out" } […]

无法JSONparsing从Node.js应用程序中从Azure服务总线收到的消息: 这是我的JS代码从Azure服务总线接收消息 function receiveMessage(serviceBusTopic, serviceBusSubscriber, callback) { serviceBus.receiveSubscriptionMessage(serviceBusTopic, serviceBusSubscriber, { isPeekLock: true }, function (error, lockedMessage) { if (!error) { try { const receivedMessage = JSON.parse(lockedMessage.body); console.log('receivedMessage', receivedMessage); if (!_.isEqual(receivedMessage.Type, messageType.USERPROFILES_USER_UPDATED)) { return; } //Message received and locked callback(receivedMessage); serviceBus.deleteMessage(lockedMessage, function (deleteError) { if (!deleteError) { // Message deleted console.log('message has been deleted.'); } }); } […]

阅读Azure服务总线队列: 我只是试图找出如何尽可能快地从Azure服务总线队列中检索邮件。我感到震惊的是，没有办法正确订阅通知队列，我将不得不进行民意调查。（除非我错了，在这种情况下文档是可怕的）。我做了很长时间的投票工作，但是每60秒查看一条消息看起来每个月会花费900英镑左右（再次，除非我误解了这一点）。如果我添加一个冗余/秒服务轮询它会翻一番。所以我想知道最好/最具成本效益的方法是什么。从本质上讲，我只是想从队列中获取消息，对一些内部保存的数据（可能使用混合服务？）执行API查找，然后可能会将消息发送回另一个队列并附加一些信息。我看着工人的angular色（？） – 这是可以做到的吗？我应该提到，我一直在用node.js来做这件事。

如何设置Azure服务总线超时: 我正在使用node.js的Azure服务总线SDK。我在sendQueueMessage中得到一个CONNECTIONTIMEDOUT错误。我想延长超时时间，但我可以在哪里configuration它。谁能帮帮我吗？

将消息传递给API时的Javascript对象编码/解码: 我将消息传递给第三方消息队列，将消息中继到我的队列侦听器（全部在node.js服务器端）。该消息具有预定义的格式，允许我定义“自定义属性”。当我提供基本types（string，数字等）时，这工作正常，但是当我尝试并在自定义属性中传递对象时，它失败。发送此消息： var info = {foo: 100}; var message = { body: 'some string', customProperties: { type: 1, name: 'test', info: info } }; 返回此消息： { body: 'some string', customProperties: { type: 1, name: 'test', info: '[object Object]' } }; 并发送此消息： var info = {foo: 100}; var message = { body: 'some string', […]

在使用node.js进行特定延迟后，从Azure ServiceBus主题发送消息: 基本上，在Azure服务总线中，我有一个主题和订阅。如果在上午11:00之前有消息到达话题，我的订阅者不应该处理它。然而，在下午14:00，我希望我的订户来对待它。有没有一种方法来实现这与本机主题filter？在有关filter的官方文档中，我没有发现任何这种用例。事实上，所有呈现的样本都是关于： “ 处理这种消息的用户，或从来没有 ”。我在找： “ 期待处理这种消息的用户，但是在特定的时间晚点 ”。

随机失败的Azure主题/订阅请求: 我正在使用Azure的服务总线（主题/订阅专门）来回发送消息。看似随意的，当发送消息到主题时，消息似乎正在消失，没有错误抛出。如果我查看Azurepipe理门户中有关该主题的图表，可以看到一部分邮件失败。 2个问题： 1 – 什么可以导致请求失败的文档在哪里？ 2 – 如何logging这些请求，以便我可以看到错误？