0

EventHub的IEventProcessor接口有如下方法:

Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages)

我想将我从 event-hub 收到的消息聚合起来TPL.DataFlow,因为原始批次太小了。通过这样做,我将不得不检查数据流管道中某处的事件,并且显然在方法返回后很长时间才会发生。

Q.1:我可以在返回context后使用参数吗?ProcessEventsAsync那有多安全?
Q.2:有没有更好的方法来做我想做的事?

4

1 回答 1

0

在研究了事件处理器源代码后,我得出结论,这不是一个好主意。PartitionContext 是可变的并且似乎不是线程安全的,因此同时调用它的方法可能会破坏它的状态。

于 2019-07-08T07:36:50.067 回答