如何通过Orca直接读取DolphinDB共享表为Orca DataFrame?
直接用Orca加载DolphinDB共享表的方法
当然可以!Orca专门提供了直接加载DolphinDB共享表的函数,完全不需要先转成pandas DataFrame,能帮你省下转换的时间开销。
你可以使用Orca的orca.load_table()函数,直接从DolphinDB服务器加载共享表为Orca DataFrame对象。具体用法如下:
import dolphindb.orca as orca # 初始化Orca并连接到DolphinDB服务器 orca.connect(host="127.0.0.1", port=8848) # 直接加载共享表tb为Orca DataFrame orca_df = orca.load_table("tb") # 之后就可以用Orca的API操作这个DataFrame了,比如查询全表 result = orca_df.select("*")
核心优势与说明:
orca.load_table()是服务器端直接映射,返回的Orca DataFrame本质是对远程共享表的引用,不会把数据拉到本地转成pandas对象,大数据量下的性能提升非常显著。- 你可以直接用Orca的类pandas语法操作这个对象,比如
orca_df.filter(orca_df["col"] > 100),所有计算逻辑都会在DolphinDB服务器端执行,避免了数据传输和格式转换的双重耗时。 - 对比你之前的方法:
s.run()会把服务器查询结果序列化后传到本地再转成pandas DataFrame,而Orca的方式全程保持数据在服务器端,本地仅持有操作句柄,效率差异会随数据量增大而愈发明显。
另外要注意,使用前确保你的Orca包版本和DolphinDB服务器版本保持一致,避免兼容性问题。
内容的提问来源于stack exchange,提问作者Irene
相关产品推荐
相关产品推荐

