EventHub的IEventProcessor
接口有如下方法:
Task ProcessEventsAsync(PartitionContext context, IEnumerable<EventData> messages)
我想将我从 event-hub 收到的消息聚合起来TPL.DataFlow
,因为原始批次太小了。通过这样做,我将不得不检查数据流管道中某处的事件,并且显然在方法返回后很长时间才会发生。
Q.1:我可以在返回context
后使用参数吗?ProcessEventsAsync
那有多安全?
Q.2:有没有更好的方法来做我想做的事?