Tag: azure eventhub

接收从Node.JS到Azure事件中心的HTTPS请求的ECONNRESET错误

我目前有一个Node.js Web API，它将HTTPS请求发送到Azure事件中心。 如果我发送单个请求或小的突发（5-7），集线器收到罚款。 但是，如果我尝试发送比这更多的信息，那么我将会收到来自集线器的ECONNRESET错误，这个错误超过了ECONNRESET （第一个ECONNRESET将通过罚款）。 （7是不是一个硬数字，它从testing到testing，但似乎是在附近） 我有一个JSON对象的数组，我通过下面的代码发送到集线器： for (var i in stack) { var obj = stack[i]; sendPayloadToEventHub(JSON.stringify(obj)); } 将JSON发送到事件中心的代码： sendPayloadToEventHub = function (payload) { var options = { hostname: config['namespace'] + '.servicebus.windows.net', port: 443, path: '/' + config['hubname'] + '/publishers/' + config['devicename'] + '/messages', method: 'POST', headers: { 'Authorization': returnSASToken(), 'Content-Length': payload.length, 'Content-Type': […]

从azure eventhub使用node.js消耗八位字节stream数据

Iam是微软事件中心的初学者。 我正在使用node js consumer从eventHub读取样本string数据。 但我需要消耗八位字节stream数据。 这是我的代码 var messageHandler = function (myIdx, msg) { console.log("############# Inside Message Handler #######"); console.log(msg.body); } 我没有得到正确的数据。 但是我成功从txt文件中读取数据。 这是我的代码 fs.readFile('/home/test/19_6.txt', function (err, data) { console.log(data); } 我做的事？ 任何想法 ？？？？ 这是我的八位字节stream数据点击这里查看

稳定节点JS AMQP 1.0客户端（事件中心）

我正在为NodeJS寻找一个稳定的AMQP 1.0客户端，以便我可以使用来自Azure事件中心的事件。 我曾尝试使用https://github.com/noodlefrenzy/node-amqp10 ，但它偶尔扼杀某些有效载荷与像malformed payload: Unknown code prefix: 0x30和malformed payload: Unable to decode bytes from message body: 005375b00002810c5b7b226576656e7474797065223 （ …）。 我将不胜感激人们在NodeJS中为稳定的AMQP 1.0客户提供的任何方向。 我很惊讶，迄今为止我还找不到一个，因为否则看起来Azure没有支持整个开发者基础。