QPython熊猫互动

假设在KDB+端有一个表t,其中有sym(symbol类型)、date(date类型)和mid(float类型)列,例如由以下代码生成:

t:`date xasc ([] sym:raze (3#) each `USDJPY`GBPUSD`EURBTC;date:9#.z.d-til 3;mid:9?`float$10)

然后,要将用于充实的数据从KDB+端带到Python端,可以执行以下操作:

from qpython import qconnection
import pandas as pd

df = pd.DataFrame({'Date': ['2018-09-08','2018-09-08','2018-09-07','2018-09-07'],'sym':['abc','def','abc','def']})
df['Date']=df['Date'].astype('datetime64[ns]')

with qconnection.QConnection(host = 'localhost', port = 5001, pandas = True) as q:
    X = q.sync('{select sym,date,mid from t where date in `date$x}',df['Date'])

结果X数据帧将sym列作为二进制字符串,因此您可能需要执行以下操作

X['sym'].apply(lambda x: x.decode('ascii'))

发送函数定义的另一种方法是在KDB+端定义一个函数,并且只从Python端发送其名称。所以,如果你能像

getMids:{select sym,date,mid from t where date in `date$x}

在KDB+方面,您可以

X = q.sync('getMids',df['Date'])

而不是发送函数定义。