denis/QuikPy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

В обработчике событий отображаем локальное время получения события + косметические изменения

Browse Source
This commit is contained in:
Игорь Чечет
2022-01-13 14:35:32 +05:00
parent a17b7dd803
commit 851073e3f8
1 changed files with 30 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

52
Examples/05 - Stream.py
View File

@@ -1,5 +1,6 @@
from datetime import datetime
import time # Подписка на события по времени import time # Подписка на события по времени
from QuikPy import QuikPy # Работа с QUIKиз Python через LUA скрипты QuikSharp from QuikPy import QuikPy # Работа с QUIK из Python через LUA скрипты QuikSharp
def PrintCallback(data): def PrintCallback(data):
@@ -8,43 +9,50 @@ def PrintCallback(data):
- Получение обезличенной сделки - Получение обезличенной сделки
- Получение новой свечки - Получение новой свечки
""" """
print(data['data']) # Печатаем полученные данные print(f'{datetime.now().strftime("%d.%m.%Y %H:%M:%S")} - {data["data"]}') # Печатаем полученные данные
if __name__ == '__main__': # Точка входа при запуске этого скрипта if __name__ == '__main__': # Точка входа при запуске этого скрипта
qpProvider = QuikPy() # Вызываем конструктор QuikPy с подключением к локальному компьютеру с QUIK qpProvider = QuikPy() # Вызываем конструктор QuikPy с подключением к локальному компьютеру с QUIK
# qpProvider = QuikPy(Host='<Ваш IP адрес>') # Вызываем конструктор QuikPy с подключением к удаленному компьютеру с QUIK # qpProvider = QuikPy(Host='<Ваш IP адрес>') # Вызываем конструктор QuikPy с подключением к удаленному компьютеру с QUIK
firmId = 'MC0063100000' # Фирма # classCode = 'TQBR' # Класс тикера
classCode = 'TQBR' # Класс тикера # secCode = 'GAZP' # Тикер
secCode = 'GAZP' # Тикер
# firmId = 'SPBFUT' # Фирма classCode = 'SPBFUT' # Класс тикера
# classCode = 'SPBFUT' # Класс тикера secCode = 'SiH2' # Для фьючерсов: <Код тикера><Месяц экспирации: 3-H, 6-M, 9-U, 12-Z><Последняя цифра года>
# secCode = 'SiH2' # Для фьючерсов: <Код тикера><Месяц экспирации: 3-H, 6-M, 9-U, 12-Z><Последняя цифра года>
# Стакан # Запрос текущего стакана. Чтобы получать, в QUIK открыть Таблицу Котировки, указать тикер
print(f'Текущий стакан {classCode}.{secCode}: {qpProvider.GetQuoteLevel2(classCode, secCode)}') # print(f'Текущий стакан {classCode}.{secCode}:', qpProvider.GetQuoteLevel2(classCode, secCode)['data'])
# Стакан. Чтобы отмена подписки работала корректно, в QUIK должна быть ЗАКРЫТА таблица Котировки тикера
qpProvider.OnQuote = PrintCallback # Обработчик изменения стакана котировок qpProvider.OnQuote = PrintCallback # Обработчик изменения стакана котировок
print(f'Подписка на стакан {classCode}.{secCode}: {qpProvider.SubscribeLevel2Quotes(classCode, secCode)["data"]}') print(f'Подписка на изменения стакана {classCode}.{secCode}:', qpProvider.SubscribeLevel2Quotes(classCode, secCode)['data'])
sleepSec = 1 # Кол-во секунд получения котировок print('Статус подписки:', qpProvider.IsSubscribedLevel2Quotes(classCode, secCode)['data'])
print(f'{sleepSec} секунд котировок') sleepSec = 3 # Кол-во секунд получения котировок
print('Секунд котировок:', sleepSec)
time.sleep(sleepSec) # Ждем кол-во секунд получения котировок time.sleep(sleepSec) # Ждем кол-во секунд получения котировок
print(f'Отмена подписки на стакан: {qpProvider.UnsubscribeLevel2Quotes(classCode, secCode)["data"]}') print(f'Отмена подписки на изменения стакана:', qpProvider.UnsubscribeLevel2Quotes(classCode, secCode)['data'])
print(f'Статус подписки: {qpProvider.IsSubscribedLevel2Quotes(classCode, secCode)["data"]}') print('Статус подписки:', qpProvider.IsSubscribedLevel2Quotes(classCode, secCode)['data'])
qpProvider.OnQuote = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию qpProvider.OnQuote = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию
# Обезличенные сделки. Чтобы получать, в QUIK открыть Таблицу обезличенных сделок, указать тикер # Обезличенные сделки. Чтобы получать, в QUIK открыть Таблицу обезличенных сделок, указать тикер
qpProvider.OnAllTrade = PrintCallback # Обработчик получения обезличенной сделки qpProvider.OnAllTrade = PrintCallback # Обработчик получения обезличенной сделки
sleepSec = 3 # Кол-во секунд получения обезличенных сделок sleepSec = 1 # Кол-во секунд получения обезличенных сделок
print(f'{sleepSec} секунд обезличенных сделок') print('Секунд обезличенных сделок:', sleepSec)
time.sleep(sleepSec) # Ждем кол-во секунд получения обезличенных сделок time.sleep(sleepSec) # Ждем кол-во секунд получения обезличенных сделок
qpProvider.OnAllTrade = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию qpProvider.OnAllTrade = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию
# Подписка на новые свечки # Подписка на новые свечки. При первой подписке получим все свечки с начала прошлой сессии
qpProvider.OnNewCandle = PrintCallback # Обработчик получения новой свечки - В первый раз получим все свечки с начала прошлой сессии # TODO В QUIK 9.2.13.15 перестала работать повторная подписка
print(f'Подписка на минутные свечки {qpProvider.SubscribeToCandles(classCode, secCode, 1)["data"]}') # Перед повторной подпиской нужно перезапустить скрипт QuikSharp.lua Подписка станет первой, все заработает
input('Enter - отмена') qpProvider.OnNewCandle = PrintCallback # Обработчик получения новой свечки
print(f'Отмена подписки на минутные свечки {qpProvider.UnsubscribeFromCandles(classCode, secCode, 1)["data"]}') print(f'Статус подписки:', qpProvider.IsSubscribed(classCode, secCode, 1)['data'])
print(f'Подписка на минутные свечки', qpProvider.SubscribeToCandles(classCode, secCode, 1)['data'])
print(f'Статус подписки:', qpProvider.IsSubscribed(classCode, secCode, 1)['data'])
input('Enter - отмена\n')
print(f'Отмена подписки на минутные свечки', qpProvider.UnsubscribeFromCandles(classCode, secCode, 1)['data'])
print(f'Статус подписки:', qpProvider.IsSubscribed(classCode, secCode, 1)['data'])
qpProvider.OnNewCandle = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию qpProvider.OnNewCandle = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию
# Выход # Выход