MASA.Framework
MASA.Framework copied to clipboard
优化IntegrationEvent事件发布
Description
使用时插入100w级数据,每次插入会发布领域集成事件,发现领域集成事件发布缓慢 阅读源码Masa.Contrib.Dispatcher.IntegrationEvents.Processor.SendByDataProcessor类发现, 分批取出IntegrationEventLog数据后是逐个调用IPublisher.PublishAsync方法,这样与dapr交互是有性能损耗的 优化建议是=>是否可以根据topicName分组,实现批量发布呢? dapr是支持批量发布的
.NET version
No response
请提供具体业务场景
请提供具体业务场景
从第三方批量抓取大量数据,在保存每一条数据时都会发布一条分析这条数据的集成事件,目前数据全部保存成功后,从IntegrationEventLog表发布集成事件的任务有性能问题,要很久才能发布完,应该是逐个调用Dapr发布事件导致有性能损耗 优化意见:同样一个topicName,可调用BulkPublishEventAsync批量发布事件