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

QUIKPy звуковое оповещение при поступлении новых данных

Browse Source
This commit is contained in:
denis
2023-02-09 20:45:51 +03:00
parent 2c89978441
commit c38ea0e153
7 changed files with 96 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
.idea/QuikPy.iml generated Normal file
View File

@@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<module type="PYTHON_MODULE" version="4">
<component name="NewModuleRootManager">
<content url="file://$MODULE_DIR$" />
<orderEntry type="jdk" jdkName="Poetry (QuikPy)" jdkType="Python SDK" />
<orderEntry type="sourceFolder" forTests="false" />
</component>
</module>

6
.idea/inspectionProfiles/profiles_settings.xml generated Normal file
View File

@@ -0,0 +1,6 @@
<component name="InspectionProjectProfileManager">
<settings>
<option name="USE_PROJECT_PROFILE" value="false" />
<version value="1.0" />
</settings>
</component>

8
.idea/modules.xml generated Normal file
View File

@@ -0,0 +1,8 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="ProjectModuleManager">
<modules>
<module fileurl="file://$PROJECT_DIR$/.idea/QuikPy.iml" filepath="$PROJECT_DIR$/.idea/QuikPy.iml" />
</modules>
</component>
</project>

65
Examples/05 - Stream.py
View File

@@ -1,7 +1,15 @@
from datetime import datetime from datetime import datetime
import os
import time # Подписка на события по времени import time # Подписка на события по времени
from QuikPy import QuikPy # Работа с QUIK из Python через LUA скрипты QuikSharp from QuikPy import QuikPy # Работа с QUIK из Python через LUA скрипты QuikSharp
from pydub import AudioSegment
from pydub.playback import play
sound_audio = None
play_audio_alert = False
def PrintCallback(data): def PrintCallback(data):
"""Пользовательский обработчик событий: """Пользовательский обработчик событий:
@@ -9,6 +17,8 @@ def PrintCallback(data):
- Получение обезличенной сделки - Получение обезличенной сделки
- Получение новой свечки - Получение новой свечки
""" """
if play_audio_alert:
play(sound_audio) # звуковое оповещение о новых данных
print(f'{datetime.now().strftime("%d.%m.%Y %H:%M:%S")} - {data["data"]}') # Печатаем полученные данные print(f'{datetime.now().strftime("%d.%m.%Y %H:%M:%S")} - {data["data"]}') # Печатаем полученные данные
def ChangedConnection(data): def ChangedConnection(data):
@@ -19,14 +29,21 @@ def ChangedConnection(data):
print(f'{datetime.now().strftime("%d.%m.%Y %H:%M:%S")} - {data}') # Печатаем полученные данные print(f'{datetime.now().strftime("%d.%m.%Y %H:%M:%S")} - {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
host = os.getenv("QUIK_HOST_0")
qpProvider = QuikPy(Host=host) # Вызываем конструктор QuikPy с подключением к удаленному компьютеру с QUIK
# classCode = 'TQBR' # Класс тикера play_audio_alert = True
# secCode = 'GAZP' # Тикер
classCode = 'SPBFUT' # Класс тикера if play_audio_alert:
secCode = 'SiH2' # Для фьючерсов: <Код тикера><Месяц экспирации: 3-H, 6-M, 9-U, 12-Z><Последняя цифра года> sound_audio = AudioSegment.from_file('../Sounds/alert_sound.wav')
classCode = 'TQBR' # Класс тикера
secCode = 'GAZP' # Тикер
# classCode = 'SPBFUT' # Класс тикера
# secCode = 'SiH2' # Для фьючерсов: <Код тикера><Месяц экспирации: 3-H, 6-M, 9-U, 12-Z><Последняя цифра года>
# Запрос текущего стакана. Чтобы получать, в QUIK открыть Таблицу Котировки, указать тикер # Запрос текущего стакана. Чтобы получать, в QUIK открыть Таблицу Котировки, указать тикер
# print(f'Текущий стакан {classCode}.{secCode}:', qpProvider.GetQuoteLevel2(classCode, secCode)['data']) # print(f'Текущий стакан {classCode}.{secCode}:', qpProvider.GetQuoteLevel2(classCode, secCode)['data'])
@@ -42,32 +59,32 @@ if __name__ == '__main__': # Точка входа при запуске это
# print('Статус подписки:', 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 = 1 # Кол-во секунд получения обезличенных сделок sleepSec = 180 # Кол-во секунд получения обезличенных сделок
# print('Секунд обезличенных сделок:', sleepSec) print('Секунд обезличенных сделок:', sleepSec)
# time.sleep(sleepSec) # Ждем кол-во секунд получения обезличенных сделок time.sleep(sleepSec) # Ждем кол-во секунд получения обезличенных сделок
# qpProvider.OnAllTrade = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию qpProvider.OnAllTrade = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию
# Просмотр изменений состояния соединения терминала QUIK с сервером брокера # Просмотр изменений состояния соединения терминала QUIK с сервером брокера
qpProvider.OnConnected = ChangedConnection # Нажимаем кнопку "Установить соединение" в QUIK qpProvider.OnConnected = ChangedConnection # Нажимаем кнопку "Установить соединение" в QUIK
qpProvider.OnDisconnected = ChangedConnection # Нажимаем кнопку "Разорвать соединение" в QUIK qpProvider.OnDisconnected = ChangedConnection # Нажимаем кнопку "Разорвать соединение" в QUIK
# Подписка на новые свечки. При первой подписке получим все свечки с начала прошлой сессии """ Подписка на новые свечки. При первой подписке получим все свечки с начала прошлой сессии """
# TODO В QUIK 9.2.13.15 перестала работать повторная подписка на минутные бары. Остальные работают # TODO В QUIK 9.2.13.15 перестала работать повторная подписка на минутные бары. Остальные работают #
# Перед повторной подпиской нужно перезапустить скрипт QuikSharp.lua Подписка станет первой, все заработает # Перед повторной подпиской нужно перезапустить скрипт QuikSharp.lua Подписка станет первой, все заработает
qpProvider.OnNewCandle = PrintCallback # Обработчик получения новой свечки # qpProvider.OnNewCandle = PrintCallback # Обработчик получения новой свечки
for interval in (60,): # (1, 60, 1440) = Минутки, часовки, дневки # for interval in (60,): # (1, 60, 1440) = Минутки, часовки, дневки
print(f'Подписка на интервал {interval}:', qpProvider.SubscribeToCandles(classCode, secCode, interval)['data']) # print(f'Подписка на интервал {interval}:', qpProvider.SubscribeToCandles(classCode, secCode, interval)['data'])
print(f'Статус подписки на интервал {interval}:', qpProvider.IsSubscribed(classCode, secCode, interval)['data']) # print(f'Статус подписки на интервал {interval}:', qpProvider.IsSubscribed(classCode, secCode, interval)['data'])
input('Enter - отмена\n') # input('Enter - отмена\n')
for interval in (60,): # (1, 60, 1440) = Минутки, часовки, дневки # for interval in (60,): # (1, 60, 1440) = Минутки, часовки, дневки
print(f'Отмена подписки на интервал {interval}', qpProvider.UnsubscribeFromCandles(classCode, secCode, interval)['data']) # print(f'Отмена подписки на интервал {interval}', qpProvider.UnsubscribeFromCandles(classCode, secCode, interval)['data'])
print(f'Статус подписки на интервал {interval}:', qpProvider.IsSubscribed(classCode, secCode, interval)['data']) # print(f'Статус подписки на интервал {interval}:', qpProvider.IsSubscribed(classCode, secCode, interval)['data'])
qpProvider.OnNewCandle = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию # qpProvider.OnNewCandle = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию
qpProvider.OnConnected = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию # qpProvider.OnConnected = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию
qpProvider.OnDisconnected = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию # qpProvider.OnDisconnected = qpProvider.DefaultHandler # Возвращаем обработчик по умолчанию
# Выход # Выход
qpProvider.CloseConnectionAndThread() # Перед выходом закрываем соединение и поток QuikPy из любого экземпляра qpProvider.CloseConnectionAndThread() # Перед выходом закрываем соединение и поток QuikPy из любого экземпляра

BIN
Sounds/alert_sound.wav Normal file
View File

Binary file not shown.

18
poetry.lock generated Normal file
View File

@@ -0,0 +1,18 @@
# This file is automatically @generated by Poetry and should not be changed by hand.
[[package]]
name = "pydub"
version = "0.25.1"
description = "Manipulate audio with an simple and easy high level interface"
category = "main"
optional = false
python-versions = "*"
files = [
{file = "pydub-0.25.1-py2.py3-none-any.whl", hash = "sha256:65617e33033874b59d87db603aa1ed450633288aefead953b30bded59cb599a6"},
{file = "pydub-0.25.1.tar.gz", hash = "sha256:980a33ce9949cab2a569606b65674d748ecbca4f0796887fd6f46173a7b0d30f"},
]
[metadata]
lock-version = "2.0"
python-versions = "^3.10"
content-hash = "2f03b13bb7a06894989a6922ca38de51da6367ba86937fefd0da29970805d73d"

15
pyproject.toml Normal file
View File

@@ -0,0 +1,15 @@
[tool.poetry]
name = "quikpy"
version = "0.1.0"
description = ""
authors = ["Your Name <you@example.com>"]
readme = "README.md"
[tool.poetry.dependencies]
python = "^3.10"
pydub = "^0.25.1"
[build-system]
requires = ["poetry-core"]
build-backend = "poetry.core.masonry.api"