TypeError: Provided value for 'message' must be of type: ServiceBusMessage in a Service Bus Queue Azure

Question

我有以下代码将 JSON 文件与 Azure 服务总线触发器连接起来，但是当触发器被激活时，我遇到了错误 TypeError: Provided value for 'message' must be of type: ServiceBusMessage。我发现以下 link 提供了某种帮助，但不是很有用

module.exports = async function (context, myBlob) {
    context.log("JavaScript blob trigger function processed blob \n Blob:", context.bindingData.blobTrigger, "\n Blob Size:", myBlob.length, "Bytes");
    if(context.bindingData.name.indexOf("json_results") == -1){
        context.log(context.bindingData.name);
        return;
    }

const data = JSON.parse(myBlob.toString());
context.log(data);

// service bus queue
const { ServiceBusClient } = require("@azure/service-bus");
// connection string to your Service Bus namespace
const connectionString = "Endpoint=sb://servicebus.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=xxxxx";



const sbClient = new ServiceBusClient(connectionString);

// name of the queue
const queueName = "service-bus-queue";
context.log("Creating queue: ", queueName);

const sender = sbClient.createSender(queueName)


try{
    // Tries to send all messages in a single batch.
    // Will fail if the messages cannot fit in a batch.
    // await sender.sendMessages(messages);
    let batch = await sender.createMessageBatch();
    for (let index=0; index < data.length; index++){
        // for each message in the array            
        // try to add the message to the batch
        if (!batch.tryAddMessage(data[index])) {            
            // if it fails to add the message to the current batch
            // send the current batch as it is full
            await sender.sendMessages(batch);

            // then, create a new batch 
            batch = await sender.createMessageBatch();

            // now, add the message failed to be added to the previous batch to this batch
            if (!batch.tryAddMessage(data[index])) {
                // if it still can't be added to the batch, the message is probably too big to fit in a batch
                throw new Error("Message too big to fit in a batch");
            }
        }
    }
    // Send the last created batch of messages to the queue
    await sender.sendMessages(batch);

    context.log(`Sent a batch of messages to the queue: ${queueName}`);

    // Close the sender
    await sender.close();
} finally {
    await sbClient.close();
}

};

如何正确转换此 JSON 文件以便将其正确发送到服务总线？

这是 JSON 文件中的一些示例数据：

[
    {
    "Id": "MCMID|10091810600907894473354109933466533357",
    "FC_rev": 0.0,
    "FC_seg": 0.0,
    "MC_rev": 0.0,
    "MC_seg": 0.0,
    "PC_rev": 0.0,
    "PC_seg": 0.0,
    "PNR_booking": 0,
    "SP_ID_f": "1009181060090789447335410993346653335721632922568DCABOI",
    "Saver_rev": 439.08,
    "Saver_seg": 8.0,
    "Total_seg": 8.0,
    "num_PAX": 2,
    "EndUserID": "oeu1632860659758r0.8453951976577427",
    "purchase_time_": "00000000000000"
},
{
    "Id": "MCMID|1015698875809402563583619705251328622",
    "FC_rev": 0.0,
    "FC_seg": 0.0,
    "MC_rev": 160.0,
    "MC_seg": 2.0,
    "PC_rev": 0.0,
    "PC_seg": 0.0,
    "PNR_booking": 0,
    "SP_ID_f": "101569887580940256358361970525132862211632922598LAXZLO",
    "Saver_rev": 0.0,
    "Saver_seg": 0.0,
    "Total_seg": 2.0,
    "num_PAX": 1,
    "EndUserID": "oeu1632922592097r0.5015812337790303",
    "purchase_time_": "00000000000000"
},
{
    "Id": "MCMID|1015698875809402563583619705251328622",
    "FC_rev": 150.08369127516778,
    "FC_seg": 1.0,
    "MC_rev": 99.77630872483222,
    "MC_seg": 1.0,
    "PC_rev": 0.0,
    "PC_seg": 0.0,
    "PNR_booking": 0,
    "SP_ID_f": "101569887580940256358361970525132862211632922598PDXLAX",
    "Saver_rev": 0.0,
    "Saver_seg": 0.0,
    "Total_seg": 2.0,
    "num_PAX": 1,
    "EndUserID": "oeu1632922592097r0.5015812337790303",
    "purchase_time_": "00000000000000"
    }
]

Answer 1

假设 data 数组中的每个元素都是一个 JSON 对象，您需要做的是将该对象转换为字符串，然后为您的对象创建一个新的 JSON 对象留言。

尝试更改以下代码行：

if (!batch.tryAddMessage(data[index])) {

到

const messageBody = JSON.stringify(data[index]);
if (!batch.tryAddMessage({body: messageBody})) {

更新

这是我试过的代码：

const { ServiceBusClient } = require("@azure/service-bus");
const connectionString = "Endpoint=sb://account.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=key";
const queueName = "queue-name";

const data = [
    {
    "Id": "MCMID|10091810600907894473354109933466533357",
    "FC_rev": 0.0,
    "FC_seg": 0.0,
    "MC_rev": 0.0,
    "MC_seg": 0.0,
    "PC_rev": 0.0,
    "PC_seg": 0.0,
    "PNR_booking": 0,
    "SP_ID_f": "1009181060090789447335410993346653335721632922568DCABOI",
    "Saver_rev": 439.08,
    "Saver_seg": 8.0,
    "Total_seg": 8.0,
    "num_PAX": 2,
    "EndUserID": "oeu1632860659758r0.8453951976577427",
    "purchase_time_": "00000000000000"
},
{
    "Id": "MCMID|1015698875809402563583619705251328622",
    "FC_rev": 0.0,
    "FC_seg": 0.0,
    "MC_rev": 160.0,
    "MC_seg": 2.0,
    "PC_rev": 0.0,
    "PC_seg": 0.0,
    "PNR_booking": 0,
    "SP_ID_f": "101569887580940256358361970525132862211632922598LAXZLO",
    "Saver_rev": 0.0,
    "Saver_seg": 0.0,
    "Total_seg": 2.0,
    "num_PAX": 1,
    "EndUserID": "oeu1632922592097r0.5015812337790303",
    "purchase_time_": "00000000000000"
},
{
    "Id": "MCMID|1015698875809402563583619705251328622",
    "FC_rev": 150.08369127516778,
    "FC_seg": 1.0,
    "MC_rev": 99.77630872483222,
    "MC_seg": 1.0,
    "PC_rev": 0.0,
    "PC_seg": 0.0,
    "PNR_booking": 0,
    "SP_ID_f": "101569887580940256358361970525132862211632922598PDXLAX",
    "Saver_rev": 0.0,
    "Saver_seg": 0.0,
    "Total_seg": 2.0,
    "num_PAX": 1,
    "EndUserID": "oeu1632922592097r0.5015812337790303",
    "purchase_time_": "00000000000000"
    }
];

const sbClient = new ServiceBusClient(connectionString);
console.log(sbClient);
console.log('===================');
const sender = sbClient.createSender(queueName);
console.log(sender);
console.log('===================');

async function sendMessages() {
  let batch = await sender.createMessageBatch();
  for (let index=0; index<data.length; index++) {
    const message = {
      body: JSON.stringify(data[index])
    };
    console.log(message);
    console.log('===================');
    if (!batch.tryAddMessage(message)) {
        // if it fails to add the message to the current batch
        // send the current batch as it is full
        await sender.sendMessages(batch);
        console.log('message batch sent...');
        // then, create a new batch
        batch = await sender.createMessageBatch();

        // now, add the message failed to be added to the previous batch to this batch
        if (!batch.tryAddMessage(message)) {
            // if it still can't be added to the batch, the message is probably too big to fit in a batch
            throw new Error("Message too big to fit in a batch");
        }
    }
  }
  if (batch.count > 0) {
    await sender.sendMessages(batch);
    console.log('message batch sent...');
  }
}

sendMessages().catch((err) => {
  console.error("The sample encountered an error:", err);
});

TypeError: Provided value for 'message' must be of type: ServiceBusMessage in a Service Bus Queue Azure

TypeError: Provided value for 'message' must be of type: ServiceBusMessage in a Service Bus Queue Azure

javascript

azure

node.js

azureservicebus

azure-functions