1

オプション データを取得するために、Python 用の Bloomberg API を使用しています。まず、オプション チェーンのすべてのシンボルを取得しました。次に、それらを使用してビッドとアスクの価格を取得しました。関数 getOptionChain を介して、400 以上のオプションがあり、結果を確認したところ、問題ありませんでした。しかし、getPX 関数を実行すると、最終的に 10 件の結果しか得られませんでした。これを調べるのを手伝ってくれる人はいますか?前もって感謝します!

import blpapi
import pandas
import csv
options = blpapi.SessionOptions()
options.setServerHost('localhost')
options.setServerPort(8194)

SECURITY_DATA = blpapi.Name("securityData")
SECURITY = blpapi.Name("security")
FIELD_DATA = blpapi.Name("fieldData")
FIELD_ID = blpapi.Name("fieldId")
OPT_CHAIN = blpapi.Name("OPT_CHAIN")
SECURITY_DES = blpapi.Name("Security Description")


def getOptionChain (sec_list):
    session = blpapi.Session(options)
    session.start()
    session.openService('//blp/refdata')
    refDataService = session.getService("//blp/refdata")
    request = refDataService.createRequest("ReferenceDataRequest")
    for s in sec_list:
        request.append("securities",s)
    request.append("fields", "OPT_CHAIN")
    cid = session.sendRequest(request)
    try:
        # Process received events
        while(True):
            # We provide timeout to give the chance to Ctrl+C handling:
            ev = session.nextEvent(500)
            response = []
            for msg in ev:
                if cid in msg.correlationIds():
                    securityDataArray = msg.getElement(SECURITY_DATA)
                    for securityData in securityDataArray.values():
                        fieldData = securityData.getElement(FIELD_DATA)
                        for field in fieldData.elements():
                            for n in range(field.numValues()):
                                fld = field.getValueAsElement(n)
                                response.append (fld.getElement(SECURITY_DES).getValueAsString())
            # Response completely received, so we could exit
            if ev.eventType() == blpapi.Event.RESPONSE:
                break
    finally:
        # Stop the session
        session.stop()
    return response



def getPX (sec_list, fld_list):
    opt_chain_list = getOptionChain(sec_list)
    session = blpapi.Session(options)
    session.start()
    session.openService('//blp/refdata')
    refDataService = session.getService("//blp/refdata")
    request = refDataService.createRequest("ReferenceDataRequest")
    for s in opt_chain_list:
        request.append("securities",s)
    for f in fld_list:
        request.append("fields",f)
    cid = session.sendRequest(request)
    try:
        # Process received events
        while(True):
            # We provide timeout to give the chance to Ctrl+C handling:
            ev = session.nextEvent(500)
            response = {}
            for msg in ev:
                if cid in msg.correlationIds():
                    securityDataArray = msg.getElement(SECURITY_DATA)
                    for securityData in securityDataArray.values():
                        secName = securityData.getElementAsString(SECURITY)
                        fieldData = securityData.getElement(FIELD_DATA)
                        response[secName] = {}
                        for field in fieldData.elements():
                            response[secName][field.name()] = field.getValueAsFloat()
            # Response completely received, so we could exit
            if ev.eventType() == blpapi.Event.RESPONSE:
                break
    finally:
        # Stop the session
        session.stop()                   
    tempdict = {}
    for r in response:
        tempdict[r] = pandas.Series(response[r])
        data = pandas.DataFrame(tempdict)
    return data
                

sec = ["IBM US Equity"]
fld = ["PX_ASK","PX_BID"]
getPX(sec,fld)

4

1 に答える 1