将来自节点js客户端的消息放入azure服务总线中的死信队列

Question

我有一个azure函数，在回调函数中，它接收来自主题的消息，有时该函数无法处理该消息，然后从该节点js代码中，我想将该消息放入死信队列，稍后可能会手动处理，我试着浏览文档，我只找到了从死信中读取消息并在从service bus对象接收消息时将其放入死信的示例，在我的情况下，这是一个回调方法，因此我不需要创建service bus对象，在回拨功能中，是否有一种方法可以将消息放入死信中

我正在使用

“@azure/服务总线”：“7.0.3”

我在跟踪这个留档

https://github.com/Azure/azure-sdk-for-js/tree/master/sdk/servicebus/service-bus/

我的职能。json是：

{
  "bindings": [
    {
      "name": "sbMessage",
      "type": "serviceBusTrigger",
      "direction": "in",
      "topicName": "dummy-topic-name",
      "subscriptionName": "dummy_subscription",
      "connection": "AzureWebJobsServiceBus"
    }
  ]
}

在本自述文件中，有一个从死信中读取的示例：

https://github.com/Azure/azure-sdk-for-js/blob/master/sdk/servicebus/service-bus/samples/typescript/src/advanced/movingMessagesToDLQ.ts

我在这个回调中得到消息：

示例代码：

module.exports = async function (context, sbMessage) {
    context.log('ServiceBus  message', sbMessage);}

Answer 1

我也在Azure总线服务上工作。

https://docs.microsoft.com/en-us/javascript/api/@azure/service-bus/servicebus接收器？查看最新的节点deadLetterMessage_ServiceBusReceivedMessage__DeadLetterOptions____key__string___any_

关于如何向DLQ传递消息的参考可以在上面的链接中找到。

基本上，您需要在所创建的接收器上调用死信消息方法。

https://github.com/Azure/azure-sdk-for-js/blob/da8d311b88dff7e93fd1835f0bf034055a8a0b2a/sdk/servicebus/service-bus/samples/javascript/advanced/movingMessagesToDLQ.js#L61-L64

    const connectionString = process.env.SERVICEBUS_CONNECTION_STRING || "<connection string>";
    const queueName = process.env.QUEUE_NAME || "<queue name>";
    const sbClient = new ServiceBusClient(connectionString);

    const receiver = sbClient.createReceiver(queueName);

    await receiver.deadLetterMessage(messages[0], {
      deadLetterReason: "Incorrect Recipe type",
      deadLetterErrorDescription: "Recipe type does not match preferences."
    });

最重要的是，您可以禁用自动完成消息来完全控制您想要如何完成或丢弃消息或将消息移动到DLQ。

Answer 2

从节点js函数抛出异常将消息置于死信队列中

Answer 3

我认为如果不建立基于服务总线的客户端（至少就NodeJs而言），直接向死信发送信息是不可能的。请检查基于NodeJS的触发器：

https://docs.microsoft.com/en-us/azure/azure-functions/functions-bindings-service-bus-trigger?tabs=javascript#usage

你会发现根本没有相应的用法（如果你基于C#，这是可能的。）。

您可以尝试创建服务总线客户端，并使用致命消息：

https://docs.microsoft.com/en-us/javascript/api/@azure/service-bus/servicebus接收器？查看最新的节点deadLetterMessage_ServiceBusReceivedMessage__DeadLetterOptions____key__string___any_