请教各位,如果在交易系统中,上游数据 api 实时推送大约500个股票的逐笔数据,那么 DolphinDB 的流计算架构怎么设计比较合适?
A: 每个股票建一个streamtable,订阅对应流表,每个消费处理一个股票的数据。
B: 设置流表使用 setStreamTableFilterColumn, 按股票hash进行数据分发,使用多个订阅,每个订阅处理一部分数据。
B