Microsoft MVP성태의 닷넷 이야기
.NET Framework: 894. eBEST C# XingAPI 래퍼 - 연속 조회 처리 방법 [링크 복사], [링크+제목 복사]
조회: 2846
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 

eBEST C# XingAPI 래퍼 - 연속 조회 처리 방법

아래의 파이썬 강좌를 보면,

[24강] xingAPI를 이용한 데이터 연속 조회 (t1301, t1310)
; https://www.youtube.com/watch?v=oargZbRv7m4

연속 조회를 처리하는 방법이 나옵니다. 규칙은 간단한데요, summary 성격의 OUTBLOCK 결과의 값을 그대로 다음번 조회 시의 INBLOCK 입력으로 넣어 주고 Request가 연속적임을 알리는 플래그를 설정하면 됩니다.

이런 처리를 XingAPINet에서는,

eBEST XingAPI의 C# 래퍼 버전 - XingAPINet Nuget 패키지
; https://www.sysnet.pe.kr/2/0/12134

다음과 같이 코딩할 수 있습니다. (bold 처리된 부분이 기존의 일반적인 쿼리 문에서와 달라진 코드입니다.)

/*
XingAPI/DevCenterSample/TR/업종/t1301/
; https://github.com/stjeong/XingAPI/tree/master/DevCenterSample/TR/%EC%97%85%EC%A2%85/t1301
*/

using (XingClient xing = new XingClient(useDemoServer))
{
    if (xing.ConnectWithLogin(user) == false)
    {
        Console.WriteLine(xing.ErrorMessage);
        return;
    }

    using (XQt1301 query = new XQt1301())
    {
        var inBlock = new XQt1301InBlock
        {
            shcode = Stock.SHCODE.KOSPI.현대건설,
            starttime = "0900",
            endtime = "1530",
        };

        while (true) // 1단계
        {
            query.SetBlock(inBlock);
            if (query.Request() < 0)
            {
                break; // 쿼리 실패
            }

            var outBlock = query.GetBlock();
            if (outBlock.IsValidData == false)
            {
                break; // 쿼리 해석 실패
            }

            foreach (var item in query.GetBlock1s())
            {
                item.Dump(Console.Out, DumpOutputType.Inline80Cols);
            }

            inBlock.CopyValueFromBlock(outBlock); // 2단계

            if (outBlock.cts_time == "") // 3단계
            {
                break;
            }
        }
    }
}

위의 코드를 말로 표현하면 다음과 같습니다.

1단계. 무한 반복 설정
2단계. 결괏값으로 나오는 outBlock의 값을 그대로 inBlock으로 복사
3단계. 마지막 연속 데이터라면 while 루프 문 탈출

이후, 연속적으로 Request()를 호출하면서 4단계의 조건이 만족될 때까지 반복

간단하죠!!! ^^




위의 코드는 연속 데이터의 끝까지 데이터를 조회하는 반면 원한다면 개수를 정하는 것도 가능합니다. 이에 대한 예제가 t1475에 나오는데요,

XingAPI/DevCenterSample/TR/업종/t1475/
; https://github.com/stjeong/XingAPI/tree/master/DevCenterSample/TR/%EC%97%85%EC%A2%85/t1475

// ...[생략]...

int pageSize = 10;
int totalSize = 30;

using (XQt1475 query = new XQt1475())
{
    XQt1475InBlock inBlock = new XQt1475InBlock
    {
        shcode = Stock.SHCODE.KOSDAQ.이베스트투자증권,
        datacnt = pageSize,
    };

    while (totalSize > 0)
    {
        query.SetBlock(inBlock);
        if (query.Request() < 0)
        {
            break;
        }

        XQt1475OutBlock outBlock = query.GetBlock();
        if (outBlock.IsValidData == false)
        {
            break;
        }

        foreach (var item in query.GetBlock1s())
        {
            item.Dump(Console.Out, DumpOutputType.Inline80Cols);
            totalSize--;
        }

        inBlock.CopyValueFromBlock(outBlock);
    }
}

t1475의 경우 InBlock에서 datacnt라는 속성이 있어 조회할 데이터 수량을 지정할 수 있습니다. 즉, 위의 경우에는 한 번에 10개씩 가져오는데 총 수량이 (최소) 30개가 될 때까지만 연속 데이터를 조회합니다. 역시 간단하죠!!! ^^




알아본 김에 Sqlite 지원도 추가했으니,

eBEST C# XingAPI 래퍼 - Sqlite 지원 추가
; https://www.sysnet.pe.kr/2/0/12145

연속 데이터를 DB에 쌓는 법도 볼까요? ^^ 아래는 t1310의 예제 코드인데,

/*
XingAPI/DevCenterSample/TR/업종/t1310/
; https://github.com/stjeong/XingAPI/tree/master/DevCenterSample/TR/%EC%97%85%EC%A2%85/t1310
*/

using (XQt1310 query = new XQt1310())
{
    var inBlock = new XQt1310InBlock
    {
        shcode = Stock.SHCODE.KOSPI.현대건설,
        daygb = XQt1310.DayGB.당일,
        timegb = XQt1310.TimeGB.틱,
    };

    bool createFirst = true;
    while (true)
    {
        query.SetBlock(inBlock);
        if (query.Request() < 0)
        {
            break;
        }

        var outBlock = query.GetBlock();
        if (outBlock.IsValidData == false)
        {
            break;
        }

        var blocks = query.GetBlock1s();

        foreach (var item in blocks)
        {
            item.Dump(Console.Out, DumpOutputType.Inline80Cols);
        }

        blocks.WriteToDB(createFirst, inBlock.shcode);
        createFirst = false;

        inBlock.CopyValueFromBlock(outBlock);
        if (string.IsNullOrEmpty(outBlock.cts_time) == true)
        {
            break;
        }
    }
}

보는 바와 같이 달라진 곳은 blocks.WriteToDB에 대한 호출 뿐입니다. 최초 호출 시에는 DB 테이블이 만들어져 있지 않으므로 첫 번째 인자(replace)에 true를 줘서 DB 테이블을 (기존에 있다면 삭제하고) 새로 생성할 수 있도록 합니다. 그다음, 두 번째 인자(tableNamePostfix)는 DB 테이블 명의 접미사인데 기본적으로 OutBlock의 이름을 사용하지만, 현실적으로 봤을 때 XQt1310 쿼리를 수행했을 때 "종목 코드(shcode)" 별로 데이터가 저장되어야 할 것이므로 "XQt1310_000720"과 같은 식의 테이블 명이 지정되도록 합니다.

이후, DB에 저장된 내용을 조회하고 싶다면 마찬가지로 접미사를 지정해 ReadFromDB 메서드를 호출하면 됩니다.

var multiBlock = XQt1310.ReadFromDB("000720"); // 000720 == 현대건설

Console.WriteLine($"# of items: {multiBlock.OutBlock1.Length}");
foreach (var item in multiBlock.OutBlock1)
{
    item.Dump(Console.Out, DumpOutputType.Inline80Cols);
}

역시 간단하죠~~~!!! ^^




마지막으로, Request() 메서드는 bNext 인자 값을 하나 받는데 기본값은 null입니다. 그냥 이렇게 null로 설정하면 최초 XQtNNNN 객체 생성 후 첫 번째 Request 호출에 대해서는 "Request(false)"로 처리하고, 그 이후의 호출에 대해서는 "Request(true)"로 처리합니다. 다음 코드는 그에 대한 사례입니다.

using (XQt1301 query = new XQt1301())
{
    // ...[생략]...
    query.Request(); // == 객체 생성 후 첫 번째 호출이므로, query.Request(false)와 동일

    // ...[생략]...
    query.Request(); // == 두 번째 호출이므로, query.Request(true)와 동일
}

따라서, 연속 데이터 조회가 아닌데도 쿼리 객체를 재사용해 Request를 사용한다면 다음과 같이 명시적으로 false 설정을 해야 합니다.

using (XQt1301 query = new XQt1301())
{
    // ...[생략]...
    query.Request(false);

    // ...[생략]...
    query.Request(false);
}

또는, XQt1301 객체 생성 후 첫 호출은 언제나 false 처리되므로 다음과 같은 식으로 매번 XQtNNNN Query 객체를 생성해 처리할 수 있습니다.

for (int i = 0; i < 2; i ++)
{
    using (XQt1301 query = new XQt1301())
    {
        // ...[생략]...
        query.Request(); // == 객체 생성 후 첫 번째 호출이므로, query.Request(false)와 동일
    }
}




[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]

[연관 글]


donaricano-btn



[최초 등록일: ]
[최종 수정일: 7/12/2021]

Creative Commons License
이 저작물은 크리에이티브 커먼즈 코리아 저작자표시-비영리-변경금지 2.0 대한민국 라이센스에 따라 이용하실 수 있습니다.
by SeongTae Jeong, mailto:techsharer at outlook.com

비밀번호

댓글 쓴 사람
 



2020-07-03 09시19분
[나그네] 그저 스치다 본 글입니다만.. 한번 해보니 잘되네요.
예전에 생각하던 그런 로직을 이걸로 구현했습니다. 덕분에 감사합니다. 많이 도움이 되었습니다.

참고로..
올려주신 로직이 잘 안되고..
그냥 인자값을 InBlock으로 넣고. 그냥 Get으로 받아서 하는게 편한듯 합니다.
이건 증권사가 초기에 만든 구조에서 변경을 한것인지 여튼.. 저의 경우는 별 생각없이 되는듯 싶네요.
//일단은.. 차트 정보를 조회해보도록 하자.
            XQt8415 q = new XQt8415();
            XQt8415InBlock args = new XQt8415InBlock();
            args.shcode = "90199999";
            //args.shcode = StockDerivative.근월물;
            args.ncnt = 1; //1분을 의미
            args.qrycnt = 500; //? 이걸 정해도.. 무조건 다 가져온다. 1분이 396개인데.. 여기 개수랑 상관이 없나?
            //args.nday = "1"; //
            args.sdate = dateString8;
            args.edate = dateString8;
            args.comp_yn = 'N'; //압축

            //1. 값을 셋팅한다.
            bool TF = q.SetBlock(args);

            //2. 요청한다.
            int x = q.Request();

            //3. 가져온다.
            XQt8415OutBlock one = q.GetBlock();
            XQt8415OutBlock1[] datas = q.GetBlock1s();
[손님]

... 16  17  18  19  20  21  22  23  24  25  26  27  28  [29]  30  ...
NoWriterDateCnt.TitleFile(s)
12234정성태6/19/20202425개발 환경 구성: 494. NuGet - nuspec의 패키지 스키마 버전(네임스페이스) 업데이트 방법
12233정성태6/19/20202234오류 유형: 619. SQL 서버 - The transaction log for database '...' is full due to 'LOG_BACKUP'. - 두 번째 이야기
12232정성태6/19/20202180오류 유형: 618. SharePoint - StoreBusyRetryLater 오류
12231정성태6/15/20202614.NET Framework: 911. Console/Service Application을 위한 SynchronizationContext - AsyncContext
12230정성태6/15/20202348오류 유형: 617. IMetaDataImport::GetMethodProps가 반환하는 IL 코드 주소(RVA) 문제
12229정성태6/13/20203180.NET Framework: 910. USB/IP PROJECT를 이용해 C#으로 USB Keyboard + Mouse 가상 장치 만들기 [1]
12228정성태6/12/20202840.NET Framework: 909. C# - Source Generator를 적용한 XmlCodeGenerator파일 다운로드1
12227정성태6/12/20206548오류 유형: 616. Visual Studio의 느린 업데이트 속도에 대한 원인 분석 [5]
12226정성태6/11/20203276개발 환경 구성: 493. OpenVPN의 네트워크 구성 [2]파일 다운로드1
12225정성태6/11/20203081개발 환경 구성: 492. 윈도우에 OpenVPN 설치 - 클라이언트 측 구성
12224정성태6/11/20206611개발 환경 구성: 491. 윈도우에 OpenVPN 설치 - 서버 측 구성
12223정성태6/9/20204226.NET Framework: 908. C# - Source Generator 소개 [6]파일 다운로드1
12222정성태6/3/20202386VS.NET IDE: 146. error information: "CryptQueryObject" (-2147024893/0x80070003)
12221정성태6/3/20202139Windows: 170. 비어 있지 않은 디렉터리로 symbolic link(junction) 연결하는 방법
12220정성태6/3/20202728.NET Framework: 907. C# DLL로부터 TLB 및 C/C++ 헤더 파일(TLH)을 생성하는 방법
12219정성태6/1/20202874.NET Framework: 906. C# - lock (this), lock (typeof(...))를 사용하면 안 되는 이유파일 다운로드1
12218정성태5/27/20202755.NET Framework: 905. C# - DirectX 게임 클라이언트 실행 중 키보드 입력을 감지하는 방법 [1]
12217정성태5/24/20202717오류 유형: 615. Transaction count after EXECUTE indicates a mismatching number of BEGIN and COMMIT statements. Previous count = 0, current count = 1.
12216정성태5/15/20203654.NET Framework: 904. USB/IP PROJECT를 이용해 C#으로 USB Keyboard 가상 장치 만들기 [14]파일 다운로드1
12215정성태5/12/20206071개발 환경 구성: 490. C# - (Wireshark의) USBPcap을 이용한 USB 패킷 모니터링 [10]파일 다운로드1
12214정성태5/5/20202870개발 환경 구성: 489. 정식 인증서가 있는 경우 Device Driver 서명하는 방법 (2) - UEFI/SecureBoot
12213정성태5/3/20203664개발 환경 구성: 488. (User-mode 코드로 가상 USB 장치를 만들 수 있는) USB/IP PROJECT 소개
12212정성태5/1/20202419개발 환경 구성: 487. UEFI / Secure Boot 상태인지 확인하는 방법
12211정성태4/27/20202537개발 환경 구성: 486. WSL에서 Makefile로 공개된 리눅스 환경의 C/C++ 소스 코드 빌드
12210정성태4/20/20203119.NET Framework: 903. .NET Framework의 Strong-named 어셈블리 바인딩 (1) - app.config을 이용한 바인딩 리디렉션 [1]파일 다운로드1
12209정성태4/13/20202555오류 유형: 614. 리눅스 환경에서 C/C++ 프로그램이 Segmentation fault 에러가 발생한 경우 (2)
... 16  17  18  19  20  21  22  23  24  25  26  27  28  [29]  30  ...