java - Azure java函数无法扩展以处理繁重的eventhub消息？

Question

我们有一个重型 Azure 函数，它使用 eventHub 触发器绑定(bind)从 eventHub1 读取数据，进行一些处理并写入另外 2 个 eventhub(eventhub2 和 eventhub3 取决于转换逻辑)。

eventHub1(12 个分区)在某一时刻有 2 亿条消息，但是该函数无法扩展以处理整个负载。在 7 天内，它只能处理 40% 的负载，最终由于 7 天保留政策，其余消息(1.2 亿)在集线器中死亡(没有被处理)。

6 天前就扩展问题向 MS 创建了支持票证。到目前为止，我们还没有收到他们任何有值(value)的回复。

我想将其呈现给这里的 azure 专家，看看你们是否有任何建议或过去遇到过类似的问题。如果您需要有关扩展问题的信息，我将非常乐意提供更多详细信息。

 - Function is on consumption plan.
 - EventHub namespace is on standard tier.
 - All the hubs has 12 partitions each.
 - MS Document says function would max have n+1 instance, where n = #of partitions. 
However from live metrics I could see function running on 27 servers instances max.

Answer 1

有几件事需要检查:

1-这是一次负载测试，您一次添加所有这些事件(但以 block 的形式)还是在工作几个小时/几天后收到？

2-您达到 TU 单位(吞吐量单位)了吗？

3-您是否启用了自动充气功能？ (https://learn.microsoft.com/en-us/azure/event-hubs/event-hubs-auto-inflate)

4-您是否考虑过使用专用集群？