javascript - 如何使用 javascript 在 azure 函数应用程序中使用服务总线主题 session

Question

我有一个 Azure Functionapp，它可以处理一些数据并将这些数据推送到 Azure 服务总线主题中。

我需要在我的 servicebus 主题订阅上启用 session 。使用 javascript functionapp API 时，我似乎找不到设置 session id 的方法。

这是我的函数应用程序的修改摘录:

module.exports = function (context, streamInput) {
  context.bindings.outputSbMsg = [];
  context.bindings.logMessage = [];

  function push(response) {
      let message = {
          body: CrowdSourceDatum.encode(response).finish()
          , customProperties: {
              protoType: manifest.Type
              , version: manifest.Version
              , id: functionId
              , rootType: manifest.RootType
        }
        , brokerProperties: {
            SessionId: "1"
        }
    context.bindings.outputSbMsg.push(message);
  }

  .......... some magic happens here.

  push(crowdSourceDatum);
  context.done();
} 

但是 sessionId 似乎根本没有设置。知道如何实现这一点吗？

Answer 1

我在我的函数上测试了 sessionid，我可以设置消息的 session id 属性并在服务总线资源管理器中查看它。这是我的示例代码。

var connectionString = 'servicebus_connectionstring';
var serviceBusService = azure.createServiceBusService(connectionString);

var message = {
    body: '',
    customProperties:
    {
        messagenumber: 0
    },
    brokerProperties:
    {
        SessionId: "1"
    }
};

message.body= 'This is Message #101';
serviceBusService.sendTopicMessage('testtopic', message, function(error)
{
    if (error)
    {
        console.log(error);
    }
});

这是测试结果。

请确保您在创建主题和订阅时已启用分区和 session 。