如何从NodeJS中的单个azure函数向azure服务总线和事件发送消息到事件集线器总线?

问题描述 投票:0回答:1

我有一个azure函数,它根据http post发送请求并获得响应;现在我想将此响应发送到服务总线和另一个事件中心(天蓝色功能由不同的事件中心触发)。

函数表示它已在事件中心的情况下成功执行,但没有发送任何事件。在服务总线的情况下,我收到此错误NamespaceConnectionString should not contain EntityPath.

module.exports = async function (context, eventHubMessages) {
    context.log(`JavaScript eventhub trigger function called for message array ${eventHubMessages}`);

    var completeData = '';

    eventHubMessages.forEach((message, index) => {
        context.log(`Processed message ${message}`);
        completeData = message;
    });

    var output = '';

    const axios = require('axios');

    try {
        const response =  await axios.post('http://fake-endpoint', 
        {  data-json : completeData
        })
        context.log(`statusCode: ${response.statusCode}`);
        context.log(response.data);
        output += response.data;

        var time = new Date().toString(); 
        context.log('Event Hub message created at: ', time);
        context.bindings.outputEventHubMessage = out;
        context.bindings.outputSbMsg = out;
        context.done()
        return response.data; // or return a custom object using properties from response
    } catch (error) {
        // If the promise rejects, an error will be thrown and caught here
        context.done(error);
    }

};

预期产出:成功执行;服务总线和事件中心可用于接收的数据。实际产量:Error: NamespaceConnectionString should not contain EntityPath.

node.js azure-functions httpresponse azureservicebus azure-eventhub
1个回答
0
投票

如错误消息所示,您需要查看连接字符串并删除EntityPath变量。 This is included如果在查看特定主题或队列时复制连接字符串,而不是从主服务总线刀片中复制它。

端点= SB:// {servicebus名} .servicebus.windows.net /; SharedAccessKeyName =测试队列的发送者; SharedAccessKey = {SharedAccessKey} =; EntityPath =测试队列;

VS

端点= SB:// {servicebus名} .servicebus.windows.net /; SharedAccessKeyName =测试队列的发送者; SharedAccessKey = {SharedAccessKey};

© www.soinside.com 2019 - 2024. All rights reserved.