小编Abe*_*Abe的帖子

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

我有一个 azure 函数,它发出一个基于 Promise 的 http post 请求并得到响应;现在我想将此响应发送到服务总线和不同的事件中心(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 …
Run Code Online (Sandbox Code Playgroud)

httpresponse node.js azureservicebus azure-eventhub azure-functions

4
推荐指数
1
解决办法
2124
查看次数