Индекс RTS упал, фьючерс на индекс упал, портфель мой чудесны образом растет. Стою в Long. Чудеса да и только. Видимо наступило время нам поддержать отечественную экономику.
Nikolay написал: И если хотите обсудить конкретное решение, то лучше для этого использовать ветку Discussions GitHub (правда если есть профиль).
Да нет спасибо, мне пока достаточно Вашего примера. Он для меня пока солоноват. Но это только пока .
Я по этой логике накидал свой шаблон, Но все что было в голове стало на беккрень Вот код
Код
local is_run;
function OnStop(flag)--вызывается при остановке скрипта из диалога управления
-- 2.2.24 Функция вызывается терминалом QUIK при остановке скрипта из диалога управления.
is_run = false
return 1000
end
function OnClose()--Функция вызывается перед закрытием терминала QUIK и при выгрузке файла qlua.dll.
is_run = false
end
--function OnInit() -- вызывается терминалом QUIK перед вызовом функции main (2.2.25 OnInit)
--end
--local class,symbol;
function main()-- Функция, реализет основной поток выполнения в скрипте.(2.2.26 main)
is_run = true;
--local list=List.new();
-- message('0 '..'first='..tostring(list.first)..'; '..'last='..tostring(list.last) )
--local AT=allt:new();
class= "SPBFUT";
symbol='RMU3'--NGN3';
-----------all_trades
--Если перечисленные параметры отсутствуют в списке полей элемента, то в качестве параметра передается nil.
function fn(par1,par2)
if par1 == class and par2 == symbol then
return true
else
return false
end
end
local t1 = nil;
--[[---- возвращает таблицу с индексами элементов, удовлетворяющих условию поиска
t1 = SearchItems("all_trades", 0, getNumberOf("all_trades")-1, fn, "class_code, sec_code")
local at=nil;
--local number_of_rows = getNumberOf('all_trades')
local first,last=1,#t1;
for i = 1, #t1 do
at = getItem('all_trades', i)
if at --and at.sec_code==symbol
then
List.pushlast(list, at);
--AllTrade();
List.popfirst(list);
end
end
--]]
local first=0;
local at = nil;
--message('1 '..'first='..tostring(list.first)..'; '..'last='..tostring(list.last) )
----
local j=1;
while is_run do ----- основной поток выполнения скриптa:
local last=getNumberOf("all_trades");
message(j..' '..'first='..tostring(first)..'; '..'last='..tostring(last) )
if last>first then
---- возвращает таблицу с индексами элементов, удовлетворяющих условию поиска При возникновении ошибки в функции fn функция SearchItems прерывает свою работу и возвращает «nil».
t1 = SearchItems("all_trades", first, getNumberOf("all_trades")-1, fn, "class_code, sec_code")
if t1 then
message(j..'): '..'first='..tostring(first)..'; last='..tostring(last)..'; #t1='..tostring(#t1) ..'; t1[1]='..tostring(t1[1])..'; t1[#t1]='..tostring(t1[#t1]))
at = {};
for i = t1[1], t1[#t1] do
if not is_run then break end
at = getItem('all_trades', i)
--if at and at.sec_code==symbol then
--List.pushlast(list, at);
--AllTrade();
--List.popfirst(list);
--end
local d = at and get_date(at.datetime) or 0;
local t = at and get_time(at.datetime) or 0;
local sec = at and at.sec_code or 'x';
local p = at and at.price or 0;
local q = at and at.qty or 0;
local dir = (at and bit.test(at.flags,0) and -1 or 1) or 0;
--if bit.test(at.flags, 0) then ---- Если сделка на продажу, вычитает объем из текущего
-- dir=-1;
--else -- Если сделка на покупку, прибавляет объем к текущему
-- dir=1;
--end
message(j..'): ('..i..'); '..tostring(d)..'; '..tostring(t)..'; '..tostring(sec)..'; '.. tostring(p)..'; '..tostring(q*dir)..'; '..tostring(dir) );
end
first=getNumberOf("all_trades");--last;--t1[#t1];
end
end
j=j+1;
--message(j..' '..'first='..tostring(first)..' list.first='..tostring(list.first)..'; '..'list.last='..tostring(list.last) )
sleep(1000);
end
end
Скрытый текст
Не получилось вставить, Но ошибка в этом исполнении не фильтрует по class_code, sec_code. Что делаю не так?
function rescanBigDeals(sec_code, class_code)
local all_trades_count = getNumberOf("all_trades")
local endIndex = LastReadDeals
local beginIndex = 1
params = {sec_code=sec_code,class_code=class_code}
local t1 = SelectItems("all_trades", 1, endIndex, params)
if t1 ~= nil then
endIndex = #t1
else
endIndex = 0
end
--myLog("rescan begin "..tostring(beginIndex).." - "..tostring(endIndex))
local lastClaster = nil
for i = beginIndex, endIndex, 1 do
local at = getItem ("all_trades", t1[i])
if at ~= nil then
local datetime = os.time(at.datetime)
if curDate.day == at.datetime.day or curDate.wday==1 or curDate.wday==7 then
local value = 0
--if CountQuntOfDeals == 1 then
-- value = 1
--elseif sum_quantity == 0 then
-- value = at.value
--else
value = at.qty
--end
local itsSell = bit.band(at.flags, 0x1) ~= 0
if dirTradeType == 2 and SecData[at.sec_code]["lastDealPrice"]~=0 and at.price~=SecData[at.sec_code]["lastDealPrice"] then
itsSell = at.price<SecData[at.sec_code]["lastDealPrice"]
end
SecData[at.sec_code]["lastDealPrice"] = at.price
--myLog("deal "..at.sec_code.." qnt "..tostring(at.qty).." deal n:"..tostring(at.trade_num).." "..isnil(toYYYYMMDDHHMMSS(at.datetime)))
if lastClaster == nil then
lastClaster = {datetime = at.datetime, mcs = at.datetime.mcs, qty = 0, value = 0, price = 0, isSell = itsSell, sellVol = 0, buyVol = 0} -- time, qty, vol, wvap
end
local needNewClaster = false
if SecData[at.sec_code]["clasterTime"] == 0 and lastClaster["mcs"] ~= at.datetime.mcs then
needNewClaster = true
elseif SecData[at.sec_code]["clasterTime"] ~= 0
and ((at.datetime.sec-lastClaster["datetime"].sec+1) > SecData[at.sec_code]["clasterTime"]
or lastClaster["datetime"].min ~= at.datetime.min or lastClaster["datetime"].hour ~= at.datetime.hour) then
needNewClaster = true
end
--myLog("needNewClaster "..tostring(needNewClaster))
if needNewClaster then
if lastClaster["value"]~=0 then
lastClaster["price"] = lastClaster["price"]/lastClaster["value"]
else
lastClaster["price"] = at.price
end
lastClaster.datetime = at.datetime
local clasterQty = lastClaster["qty"]
if SecData[at.sec_code]["bigDealSize"]~=0 and clasterQty >= SecData[at.sec_code]["bigDealSize"] then
myLog("big deal "..at.sec_code.." qnt "..tostring(clasterQty).." "..isnil(toYYYYMMDDHHMMSS(at.datetime)))
if lastClaster["buyVol"]>lastClaster["sellVol"] then
lastClaster["isSell"] = false
elseif lastClaster["buyVol"]>lastClaster["sellVol"] then
lastClaster["isSell"] = true
end
addBigDealLabel(at.sec_code, lastClaster)
end
lastClaster = {datetime = at.datetime, mcs = at.datetime.mcs, qty = 0, value = 0, price = 0, isSell = itsSell, sellVol = 0, buyVol = 0} -- time, qty, vol, wvap
end
lastClaster["qty"] = lastClaster["qty"] + at.qty
lastClaster["value"] = lastClaster["value"] + at.value
lastClaster["price"] = lastClaster["price"] + at.value*at.price
if itsSell then --sell
lastClaster["sellVol"] = lastClaster["sellVol"] + at.qty
else
lastClaster["buyVol"] = lastClaster["buyVol"] + at.qty
end
--if lastClaster == nil then
-- lastClaster = {datetime = at.datetime, mcs = at.datetime.mcs, qty = 0, value = 0, price = 0, isSell = itsSell} -- time, qty, vol, wvap
--elseif lastClaster["mcs"] ~= at.datetime.mcs then
-- lastClaster["price"] = lastClaster["price"]/lastClaster["value"]
-- local clasterQty = lastClaster["qty"]
-- if SecData[at.sec_code]["bigDealSize"]~=0 and clasterQty >= SecData[at.sec_code]["bigDealSize"] then
-- myLog("big deal "..at.sec_code.." qnt "..tostring(clasterQty).." deal n:"..tostring(at.trade_num).." "..isnil(toYYYYMMDDHHMMSS(at.datetime)))
-- addBigDealLabel(at.sec_code, lastClaster)
-- end
-- lastClaster = {datetime = at.datetime, mcs = at.datetime.mcs, qty = 0, value = 0, price = 0, isSell = itsSell} -- time, qty, vol, wvap
--end
--
--lastClaster["qty"] = lastClaster["qty"] + at.qty
--lastClaster["value"] = lastClaster["value"] + at.value
--lastClaster["price"] = lastClaster["price"] + at.value*at.price
addTradeStat(at, value, itsSell)
end
end
end
if SecData[sec_code]["showHourVWAP"] == 1 then
for k,n in pairs(SecData[sec_code]["h_vwap"]) do
addPriceLabel(sec_code, n, 3, 0)
end
end
if SecData[sec_code]["showDayVWAP"] == 1 then
addPriceLabel(sec_code, SecData[sec_code]["vwap"], 5, -2)
end
if curDate.wday==1 or curDate.wday==7 then
updateSecs()
end
rescanSec = nil
rescanning = false
end
Хочу сразу предупредить мои познания в программировании как это что не обидеть себя! Для меня смысл слова очередь - это очередь в магазине.
Как то очень сложно, про то что я писал видимость и локализацию можно забыть. 1,2,3 Ничего не вижу не знаю!
for i = beginIndex, endIndex, 1 do
local at = getItem ("all_trades", t1[i])
if at ~= nil then
local datetime = os.time(at.datetime)
if curDate.day == at.datetime.day or curDate.wday==1 or curDate.wday==7 then
Но ведь луа позволяет такие конструкции типа:
local flg = at ~= nil or urDate.day == at.datetime.day or curDate.wday==1 or curDate.wday==7 or false;
Владимир написал: Уровень подавляющего большинства посетителей форума близок к абсолютному нулю, а туде же - потоки им подавай. НА ХРЕНА ОНИ ВАМ?! С переменными та же хрень: мой скрипт может обслуживать несколько тысяч тикеров, так что переменных там, возможно, миллион - и нет проблем. Вы СВОИ задачи решайте, торговые, а не занимайтесь разной хернёй с потоками,, коллбеками, библиотеками и прочим онанизмом.
Целиком поддерживаю Вас. Не от хорошей жизни колупаемся в носу и лезем не туда. Так поделитесь опытом.
Nikolay написал: При старте внутри торговой сессии уже есть накопленные данные. Их надо перебрать (если надо). Для этого будет написан код.Далее появляются новые записи. Например, через интервал 1 сек., появилось 10-100 записей. Берем и читаем их сразу за один проход, используя тот же, уже написанный, код И это без всяких колбеков.
Но ведь это очередь.
Да хорошо ушел от колбека. Читаю таблицу можно наверное не писать а через присвоение. А что делать с индексацией? Первого нужно вести, желательно и подчистить предыдущие данные.
Ну собственно мысль я Вашу уловил. Буду пробовать.
Ziveleos, Мне не нужен это просто пример, что можно писать другие переменные.
суть другая переменная local path; локализуется в body а присвоение идет в OnInit я так делаю когда переменных >200, если меньше лучше делать как описал Владимир.
function List.popfirst (list) local first = list.first; if first > list.last then --error("list is empty") return nil end local value = list[first] list[first] = nil -- чтобы разрешить сборку мусора list.first = first + 1 return value end
Ну вот пример от автора луа list[first] = nil -- чтобы разрешить сборку мусора
Nikolay написал: Как и в предыдущей структуре скрипта Lua, после его запуска первоначально выполняются сценарии, описанные в , если они присутствуют. Далее происходит вызов обработчика с именем OnInit(), если он присутствует. В обработчике OnInit() пользователь имеет возможность инициализировать все необходимые переменные и библиотеки перед запуском отдельного потока. После завершения функции OnInit() происходит создание отдельного потока РМ QUIK, и в этом потоке начинает выполнение функция main(), которая обязательно должна присутствовать в скрипт
Владимир, Все равно не понятно, вот документация. будет OnInit() или не будет. Из body будет брать и обрабатывать. Так устроен луа, а qlua не приделах. Я думаю это больше к вопросу с видимостью в самом луа.
Nikolay написал: Речь же про колбеки звучит странно, т.к. я слабо себе представляю использование колбеков в алгоритме, если они не обработаны все. Например, запуск в середине торгового дня. Половина колбеков уже прошла, надо читать прошедшие события из таблиц, и здесь уже не важно как инициализировать. Поэтому колбеки - это вспомогательный инструмент, не более. "Прибивать гвоздями" их к логике - не самая лучшая затея. Он может и не прийти, в конечном итоге. Гарантированной доставки в документации не декларируется.
Просто из собственного опыта при запуске от колбека пришло а основной цикл еще не запущен. Прошедшие события читаю и из таблиц перед за основного цикла, после запуска беру из колбека. А какие еще варианты обработать т. всех сделок?
Владимир, Ну конечно брокер, именно он выводит наши заявки на биржу. А выводить или не выводить это его проблема. Вы видимо имеете в виду форексные дома или это про Т+2? Ну акции не просто вывести а переместить их на депозитарий.
Я о другом котировки, объем, открытый интерес и много чего а главное Параметры RM Quik - это биржа именно ее алгоритмы.
Системная математика видимо имеется в виду QUIK, но основную лепту вносит биржа. ARQA Technologies декларирует что дают то и передаем.
Согласен с Вами реализация мягко говоря не "кудышняя", одно пустое обновление версий чего стоит (windows уже отстал). Но QUIK старая система писалась еще для сибирской биржи, вот и латают как могут.
Язык бессмысленно ругать другого нет. Я люблю луа - чтоб делал без него (Qpile).
Какие из торговых алгоритмов применять дело индивидуальное. Я люблю солянку.
Событие не включать имеет мин. риск.
Но мы ведь обсуждаем Вкл. Чтоб сделку совершил, вел ее по установленным правилам RM MM и желательно закрыл в +. Да еще при всем этом желательно чтоб терминал не падал
Ну а если серьезно посмотрите TradingVieW современная более серьезная разработка со своим языком, да и профи привлекают. Правда брокер на ММВБ один Алор.
Для того чтоб слово "Робот" звучало гордо мало одного алгоритма на стек или очередь.
Как минимум нужен RM? управление позицией (MM), сама торговая система (TS) с рядом включенных стратеги и много еще всего. Вы это лучше меня знаете. Одно установления тренда с мин. отставанием чего стоит, молчу уже про применение в стратегии.
История с серебром это хорошо описанная история в экономике, когда один фонд завладел рынком серебра. Вы как программист прекрасно понимаете каких средств и алгоритмов требуется чтоб держать рынок одной бумаги.
Посмотрите договор ММ на ММИБ.
Но мы сильно отошли от темы. Если есть желание давайте отдельный топик заведем. Под названием торговые алгоритмы или еще чего.
Может кто со знатоков Lua посмотрит и протестирует данный функционал.
Хотелось бы универсальные алгоритмы реализации методов получить! Подчеркиваю никто из нас не является конкурентом друг другу.
Чтоб двинуть цену нужны Капиталы! Чтоб двинуть цену нужном направлении нужно понимание, и это не закрытые форумы. Пример тому хорошо освещенная история в трайдинге по серебру.
На Ваш вопрос - В чём преимущество? Хотел сделать поправку на пост. Если скрипт небольшой, не требует особого быстродействия, не затратен по памяти. Вас все устраивает - То ни каких.
Если хотите оптимизировать Вас скрипт посмотрите "Програмирование на Lua" сэкономит много времени. Проверено!
Я не обсуждаю язык, бессмысленно другого нет. Я лишь прислушиваюсь к рекомендациям авторов. Проверить видимость легко, быстродействие скрипта легко с локальными и глобальными. SciTe одно нажатие.
А вот со сбором мусора сложней. Оказывается nil запускает сборщик.
Владимир, так я и обращаюсь к профи, с вопросом как правильно организовать в луа; Список, стек, очередь.
Мне тяжело судить какай язык или РЕ, у меня нет подобных знаний. Пользуемся что есть, хотя мне нравится луа, интуитивно понятен.
Таблица Всех сделок отражает кто сделку организовал, больше взять негде - это собственно "Лента". А Также Количество в сделке. Баланс я имел ввиду именно Количество контрактов в сделках по направлению сделки. А так же отслеживаю крупных игроков ну и другие римочки VSA SmartM.
Я смотрел Ваши посты Как понимаю у Вас свой подход вы не пользуетесь историей данных. А локализация в луа нужна чтоб не засорять для видимости и быстродействия.
Вопрос в организации переменных Вашего скрипта их локализации и видимости.
К примеру, "перед запуском основного потока main" всего 200 локальных переменных я постоянно выхожу за это число. Если как у Космонавта то сам lua ругается порой.
Забыл сказать что получаю в колбеке обработка Main(). И сколько прилетит в колбек неизвестно даже МаркетМейкеру. Отсюда и разница в расходе памяти. один ликвидный другой не очень.
"Простейшим способом реализации очередей в Lua является использование функций ins ert и remove из библиотеки table. Эти функции вставляют и удаляют элементы из произвольной позиции массива, сдвигая остальные элементы для согласования действий. Однако, подобные перемещения могут быть дорогими для больших структур.
Более эффективная реализация использует две индекса, один для первого элемента и один для последнего:
function ListNew () return {first = 0, last = -1} end
Во избежание загрязнения глобального пространства имен мы определим все операции со списком внутри таблицы, которую мы соответственно назовем List (таким образом, мы создадим модуль)."
Код
local List = {};
function List.new()
return {first = 0, last = -1}
end
--Теперь мы можем вставлять и удалять элементы с обоих концов за постоянное время:
function List.pushfirst (list, value)
local first = list.first - 1
list.first = first
list[first] = value
end
function List.pushlast (list, value)
local last = list.last + 1;
list.last = last;
list[last] = value;
--message('List.pushlast: ' ..'; '..tostring(last)..'; '.. tostring(value.price)..'; '.. tostring(value.qty))
end
function List.popfirst (list)
local first = list.first;
if first > list.last then
--error("list is empty")
return nil
end
local value = list[first]
list[first] = nil -- чтобы разрешить сборку мусора
list.first = first + 1
return value
end
function List.poplast (list)
local last = list.last
if list.first > last then error("list is empty") end
local value = list[last]
list[last] = nil -- чтобы разрешить сборку мусора
list.last = last - 1
return val ue
end
Если вы будете использовать эту структуру для обслуживания в порядке поступления, вызывая только pushlast и popfirst, то и first, и last будут постоянно расти.
Однако, так как мы представляем массивы в Lua при помощи таблиц, вы можете индексировать их как с 1 до 20, так и с 16 777 216 до 16 777 236.
Поскольку Lua использует для представления чисел двойную точность, ваша программа можем выполняться на протяжении двухсот лет, делая по миллиону вставок в секунду, прежде чем возникнет проблема с переполнением.
Получаю, сохраняю list и уматываю. function OnAllTrade(at) if is_run and at and at.sec_code==symbol and at.class_code==class then List.pushlast(list, at); end
Получаю из list строку для обработки. function AllTrade() at = List.popfirst(list); end
Все инструмента нормально для обработки одного инструмента, но в процессе работы скрипт накапливает память.
Вопрос к Профи, как нужно сделать чтоб максимально быстро обрабатывалась и очищалась очередь? Кто то может пример показать.
зря ругаете, функция необходима и ключевое здесь OnInit(STRING script_path) В данной функции пользователь имеет возможность инициализировать все необходимые переменные и библиотеки перед запуском основного потока main().
К примеру если обрабатываете колбек OnAllTrade() без нее и не обойтись.