问题标签 [azure-eventhub]

我正在检查有关事件中心中消息保留的详细信息。假设，我已将保留政策设置为 1 天，并且我已经发送了一些消息。那么，如果我将消息retentionPolicy 更改为3 天，现有的eventData也会保留3 天吗？

我正在从一台机器测试 Azure 事件中心。

我有一个具有最大允许分区 (32) 的事件中心。

我发现写入集线器的速度非常快——基本上是 1000 条消息/秒。但是，当我尝试提取数据时，我并没有获得几乎相同的吞吐量。提取 1000 条消息大约需要一分钟。

我已经尝试过使用 32 个并行接收器的 Direct 方法和 EventHost 方法。两者在速度方面大致相同。

我已将所有设置保留为默认设置。

是因为我使用单台机器来提取数据吗？请注意，从同一台机器写入不是问题。

更新：这是我用于从事件中心提取数据的代码（直接版本）：

我在我的事件中心发布者代码中使用 SAS 令牌身份验证和设备 ID（或发布者 ID）。但是我发现即使我已经使用设备 ID 进行了身份验证，也可以使用“CreatePartitionedSender”客户端将事件发送到任何分区 ID。而我不希望在同一分区中发布两个不同的设备 ID 事件。我们是否可以添加一些自定义“授权”代码以及 SAS 身份验证，以允许对任何设备进行有限的分区访问。

向设备和分区 ID 组合添加授权背后的想法是为多个租户提供单个事件中心。如果我遗漏任何东西，请告知。

请参阅下面的发布者代码段：

与 Azure 事件中心通信时，如何通过 TLS 使用 AMQP 协议。我正在使用 AmqpTransportSettings 类，其属性 UseSslStreamSecurity 设置为 true。我没有得到任何异常，但我怎么知道我的消息是否通过 SSL 传输。是否有任何工具可以拦截 AMQP 消息通信（如 Fiddler 或 Wireshark）？另外，我们不需要像 HTTPS 那样的 SSL 证书吗？请建议我是否遗漏任何东西。

我使用了以下代码片段，但我不能确定 AMQP 是否使用 SSL：

我按照这篇文章尝试了使用 Apache Storm 的 eventthub，但是当我运行 Storm 拓扑时，它正在接收事件一分钟，然后它停止接收。所以我重新启动了我的程序，然后它正在接收剩余的消息。每次我在一分钟后运行程序时，它都无法从 eventthub 接收到。请帮助我解决问题的可能性...

我应该更改 Storm 或 Zookeeper 的任何配置吗？

Azure 事件中心是可靠的还是会丢弃事件？我无法从文档中判断它是否仅适用于可以删除事件的用例，例如温度读数，或者它是否适用于无法删除事件的场景。

我已经被困了一段时间了，我希望有人能帮助我。我正在尝试从 Azure 的 EventHub 接收数据，并使用 MVC 在 ASP.NET 页面上（实时）显示这些数据。

我找到了一种方法来创建一个等待接收事件的异步方法，我每秒用 jQuery 刷新这个方法和部分视图，但我发现随着时间的推移这给了我太多的不稳定性，它会以无限循环结束的错误。

这是我的代码：

这是我的索引视图：

http://puu.sh/gDQUj/cb816b8870.png

我希望你能看到我想要完成的事情以及它是如何失败的。

我正在考虑将 Azure 事件中心用于我目前正在从事的项目。我们今天使用服务总线队列来执行命令，这里我们为每个消息类型使用一个队列。

拥有多个事件中心是否有意义，或者将一个中心用于多种消息类型是否更好？

我正在尝试从带有 Wifi 扩展的 Arduino 向 Azure 事件中心发送消息。有没有办法在不使用提供的库的情况下上传数据？

当我们为特定类型订阅 EventHub 时。我看到我的工作人员也在继续处理旧消息。有没有办法摆脱事件中心中的旧消息或手动更改分区的偏移值在所需的消息？到目前为止，当工作人员重新启动时，我们的工作人员不会跟踪已处理的消息，检查点未保存并且旧消息被重新处理......所以任何人都可以分享摆脱这个问题的方法吗？

提前感谢，拉达。