SetUpdateCallback зависания системы

Внимание

Для участия в обсуждениях и оформления подписки на новые сообщения форума вам необходимо зарегистрироваться.
Главная » Основные форумы » Программирование на языке Lua
Страницы: 1
RSS
SetUpdateCallback зависания системы
 
#1
28.07.2016 12:22:40
Добрый день!

Не могли бы вы мне помочь с одной проблемой, уже всю голову себе сломал.

Я пытаюсь собирать данные (OHLCV) по двум классам бумаг, чтобы записывать их в локальную базу SQL.

Для этого я написал такой код, который, работает на одной-двух бумагах, но при масштабировании на оба класса он вешает QUIK. Не могли бы вы подсказать, что мне сделать, чтобы избежать этих зависаний.

Код
classes = "TQBR,TQOB";
interval = INTERVAL_M1;

function MyCallbackForAllStocks(class, security, index)
  local candle = index - 1
  local Datetime = ds:T(candle).year * 10000000000+ ds:T(candle).month * 100000000 + ds:T(candle).day*100000 + ds:T(candle).hour * 10000 + ds:T(candle).min * 100 + ds:T(candle).sec; --Получаем дату и время последней закрывшейся свечки
  local cOpen = ds:O(candle);
  local cHigh = ds:H(candle);
  local cLow = ds:L(candle);
  local cClose = ds:C(candle);
  local cVolume = ds:V(candle);
  --Затем данные упаковываются в вектор и передаются в SQL базу.
 end
end

--Создаётся обёртка
function DataSource(class,security)
 ds = CreateDataSource(class, security, interval);
 ds:SetUpdateCallback(function(index) MyCallbackForAllStocks(class,security,index) end)
end

--Скрипт запускается единожды вот такой конструкцией:
for class in string.gmatch(classes,"(%w+)") do
 local securities = getClassSecurities(class);
 for security in string.gmatch(securities,"(%w+)") do
  DataSource(class, security);
 end
end


Заранее благодарен за любую помощь и идеи.
 
 
#2
28.07.2016 14:07:23
Здравствуйте,
Попробуйте добавить обработку в функцию main
function main()
for class in string.gmatch(classes,"(%w+)") do
local securities = getClassSecurities(class);
for security in string.gmatch(securities,"(%w+)") do
 DataSource(class, security);
end
end
end
 
 
#3
28.07.2016 14:12:40
Цитата
Sergey Gorokhov написал:
Здравствуйте,
Попробуйте добавить обработку в функцию main
function main()
for class in string.gmatch(classes,"(%w+)") do
local securities = getClassSecurities(class);
for security in string.gmatch(securities,"(%w+)") do
 DataSource(class, security);
end
end
end

Пробовал не помогает. На самом деле, именно в ней у меня этот фрагмент кода и находится. У меня перед ним еще ряд условий, чтобы скрипт стартовал только раз в день, подключился к базе, обновил список бумаг в базе и т.д.
 
 
#4
28.07.2016 14:19:46
Николай,
Тогда понятно почему у нас не воспроизводится проблема.
Приведите полный код, на котором проблема повторяется.
 
 
#5
28.07.2016 16:05:28
Цитата
Sergey Gorokhov написал:
Николай,
Тогда понятно почему у нас не воспроизводится проблема.
Приведите полный код, на котором проблема повторяется.

Я разобрался, по-видимому, код работает правильно, просто изначальный процесс создания источников данных занимает очень много времени. Ну и мне пришлось каждому источнику данных уникальное имя через _G[security], иначе в таблицу подгружалась какая-то мешанина.

В связи с этим вопрос, можно ли для созданных источников данных не подгружать всю историю (3000 или сколько там свечек), а получать данные только за эту сессию?
 
 
#6
29.07.2016 06:21:15
Такой возможности нет.
 
 
#7
05.11.2016 06:16:24
Здравствуйте, я правильно понимаю, что в последней версии QUIK (Qlua) CreateDataSource может вызываться не только из main.
Или я что-то придумываю.
Есть ли возможность в последней версии вызывать ее из скриптов индикаторов.
Спасибо.
 
 
#8
05.11.2016 14:48:31
Как минимум в коде есть одна ошибка - в одну глобальную переменную ds присваиваются все создаваемые DataSource'ы. И соответственно данные читаются только из последнего созданного.

Надо изменить на что-то типа такого:
Код
--Создаётся обёртка
function DataSource(class,security)
  local [B]ds[/B] = CreateDataSource(class, security, interval);
  ds:SetUpdateCallback(function(index) MyCallbackForAllStocks(class,security[B],ds[/B],index) end)
end
 
 
#9
02.12.2016 11:56:59
Всё равно не работает.
Код
interval = INTERVAL_M1
ticker_list = "AFKS,AFLT,AKRN,ALRS,AVAZP,BANE,BANEP,CHMF,DIXY,FEES,GAZP,GCHE,GMKN,GRAZ,HYDR,IRAO,KMAZ,LKOH,LNTA,LSRG,MAGN,MFON,MGNT,MOEX,MSNG,MSRS,MSTT,MTLR,MTLRP,MTSS,MVID,NLMK,NMTP,NVTK,OGKB,PHOR,PIKK,PLZL,POLY,PRTK,RASP,ROSN,RSTI,RSTIP,RTKM,RTKMP,RUALR,SBER,SBERP,SIBN,SNGS,SNGSP,SVAV,TATN,TATNP,TGKA,TRMK,TRNFP,UPRO,URKA,VTBR,VZRZ,VZRZP,YNDX"

class="TQBR"
ds={}
is_run = true

 function mycallbackforallstocks(class,sec,index) 
   -- Теперь в колбеке нам доступны код и класс инструмента
   message(class .. " " .. security,1)
   -- Также доступны все параметры, которые приходят с колбеком из терминала
   xxx = index
end

function DataSource(class,sec,interval)
   ds[sec] = CreateDataSource(class,sec,interval)
   ds[sec]:SetUpdateCallback(function(...) mycallbackforallstocks(class,sec,...) end)
   return ds[sec]
end

function main()
    dofile(getWorkingFolder().."\\LuaIndicators\\MA.lua")
    for sec in string.gmatch(ticker_list,"%a+") do
    DataSource(class,sec,interval)
    end

    while is_run do

        for sec in string.gmatch(ticker_list,"%a+") do
            func = MA() 
            ma_out=func(ds[sec]:Size(), {Period=3, Metod = "EMA", VType="Close", round=2}, ds[sec])
        end
    end
end    


MA.lua - это файл любезно выложенный разработчиками.
Строчка 83:
Код
        EMA_TMP[I]=rounding((EMA_TMP[I-1]*(Period-1)+2*Value(I, VType, ds)) / (Period+1),round)
 
 
#10
02.12.2016 12:03:32
Космонавт,
Для расчета EMA требуется прогнать значения от первого до последнего.
Настоятельно рекомендуем посмотреть пример, который описан в файле readme_LuaIndicators.txt
 
 
#11
02.12.2016 13:26:41
И ещё вопрос

Цитата
Код
function mycallbackforallstocks(class,sec,index) 
   -- Теперь в колбеке нам доступны код и класс инструмента
   message(class .. " " .. security,1)
   -- Также доступны все параметры, которые приходят с колбеком из терминала
   xxx = index
end

function DataSource(class,sec,interval)
   ds[sec] = CreateDataSource(class,sec,interval)
   ds[sec]:SetUpdateCallback(function(...) mycallbackforallstocks(class,sec,...) end)
   return ds[sec]
end

функция mycallbackforallstocks похоже для моих целей - лишняя.
Как написать строчку
Код
ds[sec]:SetUpdateCallback(function(...) mycallbackforallstocks(class,sec,...) end)
без неё?

Вот так будет работать?
Код
ds[sec]:SetUpdateCallback()
 
 
#12
02.12.2016 13:32:09
Космонавт,
Для этого специально существует функция SetEmptyCallback
 
 
#13
02.12.2016 13:40:08
Цитата
Sergey Gorokhov написал:
Космонавт  ,
Для этого специально существует функция SetEmptyCallback
Сергей, вы программист, а я гуманитарий, уточните пожалуйста что мне делать.
Строчку
Код
ds[sec]:SetUpdateCallback(function(...) mycallbackforallstocks(class,sec,...) end)
надо заменить на
Код
ds[sec]:SetEmptyCallback () ?
в итоге я буду получать данные каждый раз при пробеге цикла, а не по апдейту?
 
 
#14
05.12.2016 07:12:38
Цитата
Космонавт написал:
надо заменить на
Да верно.
Цитата
Космонавт написал:
в итоге я буду получать данные каждый раз при пробеге цикла, а не по апдейту?
Тоже верно
 
 
Страницы: 1
Читают тему
Техническая поддержка
+7 383 219 1606
© 2000–2024,
ARQA Technologies
Наверх