Tag: azure servicebus queues

如何使用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" } […]

Azure ServiceBus令牌已过期: 我正在使用NodeJS访问Azure ServiceBus，并在几天内运行良好。突然之间，我开始接受一个错误 Subscription Deletion Error :Error: 401 – ExpiredToken: . TrackingId:xxxxxx-xxxxxxx,TimeStamp:4/8/2015 12:32:54 PM 我正在使用连接string连接到ServiceBus var azure = require('azure'); var serviceBusConnectionString = "Endpoint=sb://somens.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=mykey"; var serviceBusService = azure.createServiceBusService(serviceBusConnectionString); var rule = { deleteDefault: function () { serviceBusService.deleteRule(topicName, subscriptionName, azure.Constants.ServiceBusConstants.DEFAULT_RULE_NAME, rule.handleError); }, create: function () { var ruleOptions = { sqlExpressionFilter: subscriptionCriteria }; rule.deleteDefault(); serviceBusService.createRule(topicName, subscriptionName, filterName, […]

如何使用AMQP在“PeekLock”模式下从Azure服务总线队列获取消息？: 我们正在尝试在Node应用程序中使用Azure服务总线。我们的要求是从队列中获取多个消息。由于Azure SDK for Node不支持批量检索，因此我们决定使用AMQP。虽然我们可以按照此处所述使用Peek邮件获取邮件（ https://docs.microsoft.com/en-us/azure/service-bus-messaging/service-bus-amqp-request-response#message-operations ）。我们注意到，只要消息被提取，它们就会从队列中移除。我想知道是否有人了解如何使用AMQP和节点以“PeekLock”模式获取消息。对于AMQP，我们使用的是amqp10节点包（ https://www.npmjs.com/package/amqp10 ）。这里是我们的邮件偷看的代码： const AMQPClient = require('amqp10/lib').Client, Policy = require('amqp10/lib').Policy; const protocol = 'amqps'; const keyName = 'RootManageSharedAccessKey'; const sasKey = 'My Shared Access Key' const serviceBusHost = 'account-name.servicebus.windows.net'; const uri = protocol + '://' + encodeURIComponent(keyName) + ':' + encodeURIComponent(sasKey) + […]