问题标签 [azure-eventhub]

我正在尝试通过在本地运行火花流作业来访问事件中心数据。我在为eventhubs.checkpoint.dir. 我尝试设置低于值

• wasbs://container_name@storage_name.blob.core.windows.net/
• https://container_name@storage_name.blob.core.windows.net/
• https://storage_name.blob.core.windows.net/continer_name/

每个都导致与以下类似的错误：

我正在使用 Qpid-proton python 示例脚本（send.py）将数据发送到 Azure 事件中心。为了检查这一点，我使用了 Service Bus Explorer 2.6.1.0。使用 python 脚本发送的数据在服务总线资源管理器中显示为十六进制值，而不是我发送的数据。但是使用 Qpid 的 recv.py 接收相同的结果会产生预期的结果。那么，这是一个问题吗？

发送语法：$ python send.py -a [address] "Hello world"

我还尝试使用 Azure python SDK 发送数据。该示例数据在服务总线资源管理器中正确接收。

我正在使用Qpid-Proton-0.10 (Python)- 基于 AMQP 1.0 的消息传递库，将数据发送到Azure Event Hubs。为了接收数据，我按照以下指南使用EventProcessorHost ： https ://azure.microsoft.com/en-in/documentation/articles/event-hubs-csharp-ephcs-getstarted/#receive-messages-with-eventprocessorhost 。当通过它接收数据时，我看到在数据之前附加了两个垃圾值：

在使用Qpid-Proton 的 recv.py接收相同的字符时，我没有看到这样的字符。有人面临同样的问题吗？

PS：我还使用Azure Python SDK将数据发送到 Azure 事件中心，并使用 EventProcessorHost 和 Qpid-Proton 的 recv.py 接收它，并且没有遇到这样的问题。只是因为 Azure SDK 不包含任何接收事件的方法，我必须切换到 Qpid-Proton 库。

我正在创建一个将消息发送到 Azure 上的事件中心的 EventHub 客户端应用程序。现在，当我有一条消息要发送（每 5-6 秒）时，我创建了 EventHubClient 类的一个新实例，然后我用它来发送数据：

这是一个好习惯吗？还是只在启动时创建它然后只使用 .Send 方法更好？就性能而言，最佳方案是什么？未来发送的数量可能会增加，消息的数量也会增加

我正在编写我的第一个应用程序来从 EventHub 发送和接收。我正在遵循Azure doc中提供的示例。

我的 servicebus.properties 文件看起来像这样。

我的发件人代码如下所示

我遇到了一个例外

当我搜索解决方案时，我得到了关于 ServiceBus 队列的帮助，并且使用的连接字符串格式为 [用户名]:[密码]:[命名空间]。在 EventHub 上找不到任何帮助。

有什么建议缺少什么吗？

从以下链接中，我发现我们可以通过 AMQP 协议向发布者发送数据，https://github.com/ppatierno/azuresblite-examples。那么，如何实现相同的，即）使用 Qpid-proton python 发送到发布者（有 & 没有令牌）？

我们正在开发一个 InternetOfThings 应用程序。实际上，我们从设备获取数据并发送到 Azure 上的 EventHub。我们在现场可能会遇到很多连接问题，有时甚至会持续数天的离线时间。是否有一个库来存储和转发我们的消息并在可能的情况下转发到 eventthub？我们听说过 rabbitmq，但这里的数据量很大（每天接近 3/4 GB）。它有能力管理这些卷吗？有人经历过类似的情况吗？

We have an IoT service running on Azure which produces a lot of events. We need to build a new feature which allows our end-user to configure alerts based on system events. It allows the user to pick an event and configure an action (e-mail, webhook, etc) to be executed when such an event occurs. We're evaluating Azure Eventhub and possibly Azure Stream Analtyics as candidates for the job.

The problem we face is: We think we will get a lot of stream analytics jobs running. When for example we have 3000 customers each configuring 3 alerts we need to run 9000 stream analtyics jobs which select specific events from the eventhub pushing it in a queue which does the alert processing. This will not only be a tough maintenance job, but I think it not a really cost effective solution.

Any thoughts on this or better solutions?

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

我没有得到正确的数据。但是我成功地从 txt 文件中读取数据。这是我的代码

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

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

我是 Arduino 和 johnny-5 的新手。我不清楚约翰尼五号的工作方式。JS代码是在电脑上运行还是直接在Arduino板上运行？此外，我们可以将 johnny-5 用于 IoT 吗？因为我还没有找到任何支持 Arduino uno 连接到互联网的组件（调用 rest api 或 Azure 服务，..）

谢谢，