我有一个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.
如错误消息所示,您需要查看连接字符串并删除EntityPath变量。 This is included如果在查看特定主题或队列时复制连接字符串,而不是从主服务总线刀片中复制它。
端点= SB:// {servicebus名} .servicebus.windows.net /; SharedAccessKeyName =测试队列的发送者; SharedAccessKey = {SharedAccessKey} =; EntityPath =测试队列;
VS
端点= SB:// {servicebus名} .servicebus.windows.net /; SharedAccessKeyName =测试队列的发送者; SharedAccessKey = {SharedAccessKey};