Запрос к серверу KDB+ с использованием Python

В запросе, который вы пытаетесь выполнить, есть несколько изменений, которые должны конкретно разблокировать этот запрос.

Ошибка, которую вызывает q в этом случае, конкретно связана с / в ваших объектах datetime, чтобы решить эту проблему, вы можете передать их как строки в формате q или, возможно, более полезно передать дату и время напрямую. PyKX преобразует их из представления даты и времени в эквивалент PyKX.

from datetime import datetime
start_date=datetime.strptime("03/6/2015 12:44:31", '%m/%d/%Y %H:%M:%S')
end_date=datetime.strptime("03/6/2020 12:44:31", '%m/%d/%Y %H:%M:%S')

connection('{select datetimecol2 by col1 from table1 where col3<2, datetimecol2 within (x;y)}', start_date, end_date)

Что касается ресурсов по стороне q, книга q-for-mortals доступна по адресу https://code.kx.com/q4m3/ — отличный ресурс для начала работы со всеми элементами q, в вашем случае для в этом примере раздел q-sql здесь может представлять интерес

Ваш запрос строится на:

select col1 datetimecol2 by col1 from table1 
     where col3<`2  & datetimecol2 within (`$3/6/2015 12:44:31;`$3/6/2020 12:44:31)

Проблемы:

1. У вас нет , между именами столбцов col1 datetimecol2, это может привести к попытке использования datetimecol2 для индексации в col1, а я предполагаю, что это не то, что вы намеревались сделать. Если datetimecol2 является типом символа, эта операция завершится неудачей с type.
2. У вас есть col1 слева и справа от by, это запрещено и приведет к ошибке 'dup names for cols/groups col1
3. Вы пытаетесь создать символы со специальными символами ( и /). Их необходимо завернуть в ""
4. Вы используете col3<`2, выполняя операцию «меньше» над типом данных символа. Хотя технически это может работать, скорее всего, вам нужен числовой столбец и сравнение.
5. В предложенииwhere вы не используете & по умолчанию. , разделяет предложенияwhere

Реализация исправлений 1–5 дает работоспособный запрос:

select datetimecol2 by col1 from table1 
     where col3<2, datetimecol2 within (`$"3/6/2015 12:44:31";`$"3/6/2020 12:44:31")

6. Вы используете тип данных символа для временных меток, это неэффективно.

Ваш формат временной метки можно проанализировать с помощью q:

q)"P"$"3/6/2015 12:44:31"
2015.03.06D12:44:31.000000000

Итак, в вашей схеме вы должны использовать больше похожего на:

schema = {'col3':kx.LongAtom,
          'datetimecol2':kx.TimestampAtom,
           }

Тогда ваш запрос должен передавать параметры, а не создавать сложные строки:

from datetime import datetime
start_date = datetime.strptime("3/6/2015 12:44:31",'%m/%d/%Y %H:%M:%S')
end_date=datetime.strptime("3/6/2020 12:44:31",'%m/%d/%Y %H:%M:%S')

connection('{select datetimecol2 by col1 from table1 where
                            col3<2, datetimecol2 within (x;y)}',
              start_date, end_date)

Видеть:

• https://code.kx.com/pykx/2.5/user-guide/fundamentals/text.html
• https://code.kx.com/q/basics/datatypes/

В Академии KX есть курсы, по которым вы можете изучить q/kdb+ и PyKX. https://learninghub.kx.com/academy/