Как выполнить операцию поворота для выбора таблицы в функции тикера в KDB + / Q - PullRequest
Новая
       29

Как выполнить операцию поворота для выбора таблицы в функции тикера в KDB + / Q

2 голосов
/ 26 октября 2019

Я пытаюсь выполнить операцию поворота для выбора, сделанного в функции тикера, следующим образом: 

// Trades table
trades:(
 []time:`timespan$();
 sym:`symbol$();
 exch:`symbol$();
 side:`symbol$();
 price:`float$();
 size:`float$());

// Generic pivot function
piv:{[t;k;p;v]f:{[v;P]`${raze "_" sv x} each string raze P,'/:v};v:(),v; k:(),k; p:(),p;G:group flip k!(t:.Q.v t)k;F:group flip p!t p;key[G]!flip(C:f[v]P:flip value flip key F)!raze{[i;j;k;x;y]a:count[x]#x 0N;a[y]:x y;b:count[x]#0b;b[y]:1b;c:a i;c[k]:first'[a[j]@'where'[b j]];c}[I[;0];I J;J:where 1<>count'[I:value G]]/:\:[t v;value F]};

 // Ticker function that "ticks" every 5 seconds
if[not system"t";system"t 5000";
 .z.ts:{
    // Selection is made from the trades table with the index reset
    trds:0!select first_price:first price, last_price:last price, mean_size:avg size, volume:sum size, min_price:min price, max_price:max price by time:1 xbar time.second, exch, sym from trades;

     // Check if selection returns at least one row and run pivot   
    if[(count trds)>0; (
        ptrds:piv[`trds;`time;`exch`sym;`first_price`last_price`mean_size`min_price`max_price`volume];
        show ptrds;
    )];

 }];

Однако это не работает как trds reference made in the pivot function is not picked up, presumably because the trds selection is not global, however whilst using trds (without) в качестве параметра, которым функция piv так или иначе являетсяне применяется и возвращает результат, как будто никакая операция не была выполнена. Кроме того, необходимость создания дополнительной переменной с помощью ptrds кажется неэффективной, а также выдает ошибку ссылки. Может кто-нибудь, пожалуйста, посоветуйте мне, как я могу реализовать эту логику эффективным каноническим способом. Спасибо

1 Ответ

3 голосов
/ 27 октября 2019

Я думаю, что источником вашей ошибки здесь являются () скобки в вашем последнем утверждении if. Проблема в том, что, когда несколько скобок заключены в квадратные скобки, объект становится списком. В kdb элементы списка оцениваются справа налево, например, 

q)(a:10;a+15)     
'a                
  [0]  (a:10;a+15)
             ^    
q)(a+15;a:10)     
25 10

Чтобы решить вашу проблему, просто снимите скобки так, чтобы он читался как 

if[(count trades)>0;ptrds:piv[...];show ptrds;]
...