1

我是 Microsoft 活动中心的初学者。我正在使用节点 js 消费者成功地从 eventHub 读取示例字符串数据。但我需要使用八位字节流数据。这是我的代码

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);
}

我所做的?任何想法 ????

这是我的八位字节流数据点击这里查看

4

1 回答 1

2

根据我的经验,您可以将文件读取为字节数组并使用 Base64 编码将其转换为字符串,然后将 Base64 字符串发送到 EventHub。收到数据后,可以将 Base64 字符串解码为字节数组。

但我不推荐这种方式,因为 EventHub 中存在一些限制。

首先,事件中心事件的最大大小为 256KB。超过此配额的消息将被拒绝,调用代码将收到异常。请参阅https://azure.microsoft.com/en-us/documentation/articles/service-bus-quotas/

在此处输入图像描述

其次,您需要使用一些 C# API,例如 Event Processor Host API 来接收来自 Event Hubs 的消息。请参阅https://azure.microsoft.com/en-us/documentation/articles/event-hubs-programming-guide/#event-consumers。如果你想用 NodeJS 来做,虽然 Event Hub/Service Bus 支持 AMQP 协议,但会很困难。

所以我认为您想知道如何将文件发送到队列并接收它们以执行某些过程。我建议您使用 Azure 存储队列来实现您的想法。

关于从 NodeJS 使用 Storage Queue,请参考https://azure.microsoft.com/en-us/documentation/articles/storage-nodejs-how-to-use-queues/http://azure.github.io /azure-storage-node/#toc7

于 2015-10-07T06:21:41.797 回答