- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有一个生产者将消息写入 Azure 事件中心,还有一个使用者从事件中心读取消息。我将生产者升级到 .Net core,并在此过程中从使用 WindowsAzure.ServiceBus 包切换到 Azure.Messaging.EventHubs 来将消息写入事件中心。
来自旧生产者的事件仍在处理中,没有问题。但是,当消费者收到来自新生产者的任何消息时,我发现事件处理器在处理我的事件之前抛出异常。
Unable to cast object of type 'System.Collections.Generic.List`1[System.Diagnostics.Activity]' to type 'System.Collections.Generic.IEnumerable`1[System.Diagnostics.Activity]'
此消息不会显示在 Azure 的日志输出中,但会显示在 Application Insights 中。 当我在本地计算机上运行时,不会引发异常。
此问题已 reported as a bug在官方 Azure Functions EventHub 存储库上。在评论中,用户提到该问题是在 4.1.0 版本中引入的,恢复到 4.0.1 修复了该问题。
我恢复到4.0.1,它停止了抛出异常,但是旧消息和新消息之间仍然存在差异。我正在使用 Microsoft.Azure.Functions.Extensions 进行依赖项注入(inject)。每当我收到一批完全旧的消息时,就没有问题。但是,当我收到包含新消息的批处理时,依赖项注入(inject)范围没有配置服务。
如果我在本地运行该项目,则没有问题。只有当我部署到 Azure Functions 环境时才会出现这些问题。
到目前为止,我已经:
Microsoft.Azure.EventHubs
,以便发布者和使用者使用相同的包我尝试思考我的本地环境和 Azure Functions 环境之间可能存在哪些不同,以便我看到行为上的差异。
本地:
azure :
最佳答案
根据原发帖者的评论分享答案:
将消费者恢复为 Microsoft.Azure.WebJobs.Extensions.EventHubs 4.0.1
并将发布配置文件更改为 <SelfContained>false</SelfContained>
已解决问题。
关于c# - Azure.Messaging.EventHubs 与 WindowsAzure.ServiceBus 生成的消息有区别吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63716454/
我正尝试按照教程实现接收器部分 https://azure.microsoft.com/en-us/documentation/articles/event-hubs-java-ephjava-get
我想发送给eventhub客户,然后将其下载到示例数据(例如天气)并发送另一个eventhub。我的代码无法正常工作。没有错误,但数据没有发送到数据库。 public Task ProcessEven
在我的应用程序中,发布到 Eventhub 的各种事件。但是我的消费者群体只需要特定的一组事件。如何在 Eventhub 中过滤这个? 最佳答案 关注此 post : event hubs doesn
比方说,当处理来自 Azure EventHub 的批量事件时发生 transient 故障并且 transient 故障即使在重试后仍然持续,那么可以从处理器向 Eventhub 抛出哪种异常?以便
没有现成的解决方案可以将数据从一个 Azure EventHub 克隆到另一个 EventHub。有哪些可能的选择来实现这一目标? 最佳答案 复制 Azure EventHub 流的一个简单选项是在
Azure 事件中心发布了一个现代客户端库 (Azure.Messaging.EventHubs),用于读取和写入事件中心。新库应该取代旧库 (Microsoft.Azure.EventHubs),所
我的要求是使用 Spring 的 Azure 事件中心进行简单的发布-订阅。 在检查文档后,我发现了 2 篇文章演示了集成。 One uses azure-eventhubs图书馆和the other
我的要求是使用 Spring 的 Azure 事件中心进行简单的发布-订阅。 在检查文档后,我发现了 2 篇文章演示了集成。 One uses azure-eventhubs图书馆和the other
我需要获取 EventHub 的分区列表。我正在尝试使用最新 SDK 中的 EventProcessorClient。这似乎没有 getRuntimeInformation 方法。 有什么方法可以使用
作为安全产品的一部分,我拥有大规模云服务(azure 辅助角色),它从事件中心读取事件,将它们批量处理到约 2000 个,然后存储在 blob 存储中。每个事件都有一个 MachineId(发送该事件
升级 然后构建 返回 “命名空间“Microsoft.Azure”中不存在类型或命名空间名称“EventHubs”(是否缺少程序集引用?)[sss-af-filter]” “找不到类型或命名空间名称“
使用 Event Hub Premium 时我们必须计算的 Azure Event Hub 吞吐量限制是多少? The documentation说使用高级层时每个 PU 没有限制,但我不明白这意味着
实际上是在尝试做一些我不擅长的事情。 我在这里阅读了持久功能概述 - https://learn.microsoft.com/en-us/azure/azure-functions/durable/d
我在 java 中运行事件中心函数的发送者类应用程序。 下面是输出: [main] INFO com.azure.messaging.eventhubs.EventHubClientBuild
全部, 我设置了 EventHub 命名空间和 EventHub,并能够使用 Python 脚本成功向其发送和接收事件。我还能够启用捕获功能并将事件以 Avro 格式存储在 Azure Blob 存储
为什么我们需要 Azure 存储帐户上的 blob 容器用于 Eventhub 消费者客户端(我使用的是 python)。为什么我们不能像在 Kafka 中那样直接使用来自 Eventhub(Kafk
全部, 我设置了 EventHub 命名空间和 EventHub,并能够使用 Python 脚本成功向其发送和接收事件。我还能够启用捕获功能并将事件以 Avro 格式存储在 Azure Blob 存储
我们正在开发一个 Multi-Tenancy 应用程序,其中 eventhub 将在不同租户之间共享。我们将在租户之间分配分区。每个租户将在不同的分区上发送消息。我们希望在分区级别对租户进行身份验证。
据我了解,eventhub 每秒可以处理/摄取数百万条消息。为了调整摄取,我们可以使用吞吐量。 更高的吞吐量=更强的摄取能力。 但是在接收/消费方面,您最多可以创建 32 个接收者(因为我们可以创建
为什么我们需要 Azure 存储帐户上的 blob 容器用于 Eventhub 消费者客户端(我使用的是 python)。为什么我们不能像在 Kafka 中那样直接使用来自 Eventhub(Kafk
我是一名优秀的程序员,十分优秀!