问题标签 [azure-eventhub]

我正在寻找 SignalR 的高频缩放解决方案。我想知道我是否可以使用 Azure EventHub 来做到这一点。如果我使用 EventHub 作为 SignalR 消息的底板，它会成为我的瓶颈吗？

我已经检查了这个页面，但没有关于 EventHub 的内容，因为它是相当新的。

这是场景。我不使用实时数据。相反，我从我的电力公司获取过去一天用电量的数据。具体来说，每天我都可以在过去一天的时钟上获得每小时的千瓦时数。

因此，我想每天将这些过去的信息加载到事件中心。这是可行的吗？事件中心是否支持加载过去的信息，或者它只是永远关于实时流数据，无法加载过去的数据？

恐怕是这种情况，因为我没有在我能找到的有限 api 文档中看到任何日期规范。不过我想确认...

谢谢，约翰

我找不到任何使用 Python 在线订阅和使用来自 Azure 事件中心的消息的文档。我知道这在 C、C# 和 Java 中是可能的。我只需要知道是否可以使用 Python。

Azure python SDK 目前似乎只支持发送消息，但不打开异步连接以不断接收来自事件中心的消息。 http://azure-sdk-for-python.readthedocs.org/en/latest/servicebus.html#event-hub

我正在使用 Azure 流分析，我的输入是 Eventhub，事件序列化格式是 CSV，DELIMITER 是逗号（，）。我的查询是从输入中选择 DeviceId，温度，我的输出是 sql 数据库。但是当我的工作正在运行时，它给了我类似的错误

“反序列化后，发现 0 行。如果这不是预期的，可能的原因可能是缺少标题或格式错误的 CSV 输入”

第二个错误是

无法将输入事件反序列化为 Csv。一些可能的原因：

1) 畸形事件

2）输入源配置错误的序列化格式..

我正在像这样在 Eventhub 上发送数据

我有一个使用事件中心接收数据的项目，每秒发送一次，数据由使用 SignalR 的网站接收，一切正常，我一直通过流分析作业将数据存储到 blob 存储中，但这真的很慢，而且我只收到 6 台设备的数据量，随着数据的增加，它会变得更慢，我需要访问数据以通过网站上的图表显示历史数据，并且然后用进来的实时数据来补充。

我真的不需要每秒存储一次数据，所以考虑只每 30 秒存储一次，但是到 SQL DB 中，我想要做的仍然是每秒接收数据，但每 30 秒存储一次，我尝试了一个翻滚窗口，但据我所知，这只是每 30 秒转储一次所有内容，而不是单个条目。

我是否想念翻滚、滑动和跳跃窗口，我猜我不能以这种方式使用它们？如果是这种情况，我猜唯一的方法就是将输出数据库作为输入，这样我就可以将时间戳与当前时间交叉引用？

除非有人有其他想法？任何帮助，将不胜感激。

谢谢

我目前正在使用 EventProcessorHost 和一个简单的 IEventProcessor 实现来实现一个事件中心阅读器。我已经确认遥测数据正在使用 Paolo Salvatori 出色的Service Bus Explorer写入事件中心。我已成功将 EventProcessorHost 配置为使用存储帐户进行租约和检查点。我可以在存储帐户中看到事件中心数据文件。我此时看到的问题是 IEventProcessor 实现似乎没有从事件中心读取任何内容。

我没有收到任何例外。测试控制台应用程序连接到存储帐户没有问题。我注意到我添加到构造函数的日志语句从未被调用，因此看起来接收器从未真正被创建。我觉得我错过了一些简单的东西。谁能帮我确定我错过了什么？谢谢！

IEventProcessor实现：

测试控制台代码：

我目前正在使用amqp.net lite从我的树莓派向 azure eventthub 发送消息。

我的连接字符串如下所示：amqps://SendMessage:[url 编码键]@[sb 命名空间]

这很好用，但现在我想改用 SAS 令牌。在这种情况下，有效的连接字符串会是什么样子？到目前为止，我尝试的任何方法都没有为我工作。

PS 我没有使用微软的官方 NuGet 包，因为它不适用于单声道

因此，我已经通过 Python、C# 和 JavaScript 使用 Azure 事件中心大约一年了。最近（一周半），Python 和 JavaScript 停止工作，发布请求返回 40100 未经授权。其他人也有这个问题吗？您必须将发布请求发送到 Azure 事件中心的方式是否有某种更新？我以前的任何应用程序都没有改变。

Python Azure SDK：天蓝色 0.10.2 https://pypi.python.org/pypi/azure/0.10.2

JavaScript Azure 服务总线 SDK https://github.com/ddobric/ServiceBusJavaScriptSdk

我尝试在两个单独的 Azure 帐户、@hotmail 和企业订阅上创建事件中心。从事件中心级别的发送策略到管理策略，再到服务总线级别的 RootManagedAccess 密钥，我已经授予了所有访问权限。这些都不起作用。

我刚刚测试了这个应用程序，它也不再能够发送到事件中心。这是一个用于 TI 传感器标签的连接点 MSDN 应用程序。 https://github.com/sudheshk/TISensorToEventHub_WindowsForm

• 我正在使用 Eventhub，我想用 eventthub 连接数百万台设备。我的场景是一种流分析正在从 eventthub 读取数据或某些接收器应用程序也在运行。但是当连接数大于 5 时，某些接收器应用程序停止（错误：同一消费者组上允许的连接数不超过 5 个）。经过一些研发我已经设置了所有接收器的纪元，所以这样做不会发生任何错误。所以我的问题是与所有接收器设置相同的纪元，我们可以创建多少连接，或者如果 5 个连接是 eventthub 的限制，那么我如何读取百万设备数据。
• 第二个问题是流分析设置了什么时代，我如何知道哪个时代是由哪个流分析设置的，以便当我的接收器服务启动时，连接将始终通过这些应用程序而不是流分析获得，（通过为接收器设置更高的值应用）。
• 在 eventthub 上发送数据允许多少连接以及在 eventthub 上允许多少接收器连接。

我的设备使用 c++ 语言中的 Encoding.UTF8 在 eventthub 上发送数据。我的接收器是用 c# 编写的。从 Eventhub 接收数据时（字符串正文 = Encoding.UTF8.GetString(message.GetBytes());）逗号替换为%2c

• 我的 eventthub 消息是DeviceID,Temprature,Humidity\nfdf5d821-c490-4405-b84c-171b478666d1,55,65

• 但是 c# 中的字符串返回是

  设备ID%2CTemprature%2CHumidity%0Afdf5d821%2Dc490%2D4405%2Db84c%2D171b478 666d1%2C55%2C65

• 我的第一个问题是如何接收数据，就像我在 c# 中没有特殊字符的情况下发送到 eventthub 一样
• 当 Stream 分析运行时，它是否从 eventthub 读取数据？