如何使Python库Ray共享内存可写？

Question

一点背景： 我正在写一个股票回溯测试程序，它订阅一个websocket提要，在一分钟内为100多只股票流式传输数据。由于这是一个反向测试程序，它实际上是由我的本地数据提供的

我试图利用光线进行多处理

因此，它将在本地接收循环中的股票数据，例如a、B、C。。。。A、 B，C。。。持续到时间段结束。目前，我对Ray的设置是为每个股票数据异步调用handleStock.remote()。出于性能原因，每次处理相同的库存但不同的时间时，都应该有一些缓存来帮助更快地处理。但由于每次库存都是作为一个全新的进程/工作进程在Ray中运行的，因此我无法共享内存并对其进行写入。我尝试了Rayput方法，但它是只读的

是否有解决此问题的方法或其他工具来运行此回测

Answer 1

“光线对象存储”值将成为第一个写入程序。这里一个可能的选择是将数据存储在actor中，而不是对象存储中

如果您确实需要返回对象，并且性能很重要，那么可以将操作分解为两个异步操作

1. 计算
2. 返回结果