我试图从静态csv文件模拟实时数据流。
有2个csv文件。
exchange.csv：每日货币汇率

DATE        CURRENCY    RATE
2020-01-01  USD         1.1
2020-01-03  USD         1.2

利率1.1意味着：1欧元=1.1美元
balance.csv：账户余额状态

ACCOUNT     BALANCE     CURRENCY    DATETIME
A           100         USD         2020-01-02 0:00
B           200         EUR         2020-01-02 0:00
A           150         USD         2020-01-02 12:00
B           200         EUR         2020-01-02 12:00
A           150         USD         2020-01-03 0:00
B           300         EUR         2020-01-03 0:00
A           50          USD         2020-01-03 12:00
B           0           EUR         2020-01-03 12:00

我正在使用spool dir阅读两个主题：
平衡主题
交换主题
我想将两个流主题合并为一个，以便根据汇率更新余额中的货币数据：

结果主题应该是这样的：

ACCOUNT     BALANCE     CURRENCY    DATETIME
A           100         USD         2020-01-02 0:00
B           220         USD         2020-01-02 0:00
A           150         USD         2020-01-02 12:00
B           220         USD         2020-01-02 12:00
A           150         USD         2020-01-03 0:00
B           360         USD         2020-01-03 0:00
A           50          USD         2020-01-03 12:00
B           0           USD         2020-01-03 12:00

我如何实现这样的逻辑？