У меня есть лазурная функция, которая делает HTTP-почтовый запрос на основе обещаний и получает ответ; теперь я хочу отправить этот ответ на служебную шину и в другой концентратор событий (функция azure запускается другим концентратором событий).
функция сообщает, что в случае концентратора событий она была выполнена успешно, но события не отправляются. В случае служебной шины я получаю эту ошибку 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.