IBrokers twsFOP call в R

Я пытаюсь получить следующие данные, чтобы получить некоторые данные из IB (данные о фьючерсных опционах Nasdaq 100 e-mini). Я использую обратный вызов snapShot (приведен ниже). Может ли кто-нибудь сказать мне, что не так с моим кодом?

require(IBrokers)
tws <- twsConnect()
test3<- twsFOP("NQ","GLOBEX",expiry="20141121",strike="4000",right="C")
test4 <- reqMktData(tws, test3, eventWrapper=eWrapper.data(length(1)),CALLBACK=snapShot)

Огромное спасибо. Я искал в Интернете и нашел мало документации по twsFOP, кроме документации CRAN, которая указывает на twsFuture. Снимок вызова включен ниже:

snapShot <- function (twsCon, eWrapper, timestamp, file, playback = 1, ...)
{
  if (missing(eWrapper))
    eWrapper <- eWrapper()
  names(eWrapper$.Data$data) <- eWrapper$.Data$symbols
  con <- twsCon[[1]]
  if (inherits(twsCon, "twsPlayback")) {
    sys.time <- NULL
    while (TRUE) {
      if (!is.null(timestamp)) {
        last.time <- sys.time
        sys.time <- as.POSIXct(strptime(paste(readBin(con,
                                                      character(), 2), collapse = " "), timestamp))
        if (!is.null(last.time)) {
          Sys.sleep((sys.time - last.time) * playback)
        }
        curMsg <- .Internal(readBin(con, "character",
                                    1L, NA_integer_, TRUE, FALSE))
        if (length(curMsg) < 1)
          next
        processMsg(curMsg, con, eWrapper, format(sys.time,
                                                 timestamp), file, ...)
      }
      else {
        curMsg <- readBin(con, character(), 1)
        if (length(curMsg) < 1)
          next
        processMsg(curMsg, con, eWrapper, timestamp,
                   file, ...)
        if (curMsg == .twsIncomingMSG$REAL_TIME_BARS)
          Sys.sleep(5 * playback)
      }
    }
  }
  else {
    while (TRUE) {
      socketSelect(list(con), FALSE, NULL)
      curMsg <- .Internal(readBin(con, "character", 1L,
                                  NA_integer_, TRUE, FALSE))
      if (!is.null(timestamp)) {
        processMsg(curMsg, con, eWrapper, format(Sys.time(),
                                                 timestamp), file, ...)
      }
      else {
        processMsg(curMsg, con, eWrapper, timestamp,
                   file, ...)
      }
      if (!any(sapply(eWrapper$.Data$data, is.na)))
        return(do.call(rbind, lapply(eWrapper$.Data$data,
                                     as.data.frame)))
    }
  }
}

person jd8585    schedule 01.10.2014    source источник
comment
что происходит, когда вы пытаетесь бежать?   -  person DMT    schedule 02.10.2014
comment
Выглядит правильно для меня. Я реализовал точно такая же функция, и я знаю, что она работает для фьючерсов, опционов, акций и FX (я не пробовал FOP). Когда я запускаю ваш код, я могу подключиться к ферме рыночных данных. Вы не получите никаких данных, пока не произойдет изменение цены на рынке.   -  person GSee    schedule 02.10.2014


Ответы (1)


Функция не вернется, пока не будет обновлена ​​​​цена.

Если я меняю инструмент на будущее, он работает просто отлично.

test3<- twsFUT("NQ","GLOBEX",expiry="20141219")
test4 <- reqMktData(tws, test3, eventWrapper=eWrapper.data(length(1)),CALLBACK=snapShot)
test4
#     BidSize BidPrice AskPrice AskSize    Last LastSize Volume
#NQZ4      14     3984  3984.25       1 3984.25       11   1702

Ваш инструмент FOP кажется действительным, потому что вы можете позвонить reqContractDetails(tws, test3) и получить обратно все детали контракта.

Наконец, использование вызова рыночных данных с контрактом FOP также выглядит правильным. Я могу подключиться к ферме рыночных данных, используя ваш код...

test3<- twsFOP("NQ","GLOBEX",expiry="20141121",strike="4000",right="C")
reqMktData(tws, test3, eventWrapper=eWrapper.data(length(1)),CALLBACK=snapShot)
#2 -1 2104 Market data farm connection is OK:usfuture 
#2 -1 2106 HMDS data farm connection is OK:ushmds.us 
#2 -1 2107 HMDS data farm connection is inactive but should be available upon demand.cashhmds 
#2 -1 2106 HMDS data farm connection is OK:ushmds 

Теперь нам просто нужно дождаться обновления цен.


Если вам нужна последняя цена, не дожидаясь обновления, вы можете получить ее, используя reqHistoricalData, с текущим временем в качестве endDateTime. Если вам нужны данные для Bid, Ask и Trades, вам нужно сделать 3 отдельных запроса. Вот как получить последнюю сделку из службы исторических данных

dat <- reqHistoricalData(tws, test3, 
                  endDateTime=paste(format(Sys.time(), "%Y%m%d %H:%M:%S")), 
                  barSize="1 min", 
                  duration="5 D", useRTH=0, whatToShow="TRADES")
#waiting for TWS reply on NQ .... done.
last(dat)
#                    NQX4 C4000.Open NQX4 C4000.High NQX4 C4000.Low NQX4 C4000.Close NQX4 C4000.Volume NQX4 C4000.WAP
2014-10-01 16:14:00          101.75          101.75         101.75           101.75                 0         101.75
                    NQX4 C4000.hasGaps NQX4 C4000.Count
2014-10-01 16:14:00                  0                0

Вам нужно будет использовать whatToShow="BID" и whatToShow="ASK" для получения данных Bid и Ask.

person GSee    schedule 02.10.2014
comment
Спасибо всем за помощь. Возможно ли получить последнюю цену или лучше, текущую цену покупки или продажи, не дожидаясь нового обновления цены? - person jd8585; 02.10.2014
comment
@ jd8585 Не совсем. Вы можете reqHistoricalData. Я обновлю ответ. - person GSee; 02.10.2014