1

我开始使用 RxPy，但我找不到流式传输表示带有时间戳的股票行情的 csv 文件的方法。有人可以帮助我了解如何使用调度程序返回到我的第一个刻度，然后以确切的时间戳从 csv 流式传输每一行吗？

from rx import Observable
from rx.concurrency import HistoricalScheduler
import pandas as pd
from datetime import datetime

df = pd.read_csv("eurusd.csv", names=['Symbol', 'Date', 'Bid', 'Ask'])
df['Date'] = pd.to_datetime(df['Date'])

startTime = df['Date'][0]
scheduler = HistoricalScheduler(startTime)

observable = Observable.from_iterable(df, scheduler=scheduler).timestamp(scheduler=scheduler)
observable.map(lambda l: l)
observable.subscribe(lambda s: print(s))

scheduler.start()

您可以在此处下载 csv 文件。

编辑：

我试图从这个博客转换 RxJS 代码但没有成功：

observable = Observable.for_in(df, lambda t: Observable.timer(t['Date'].timestamp.date(), scheduler).map(lambda l: l)) 
observable.subscribe(lambda s: print(s))

有人可以帮我解决这个问题吗？

4

0 回答 0