Microsoft MVP성태의 닷넷 이야기
.NET Framework: 894. eBEST C# XingAPI 래퍼 - 연속 조회 처리 방법 [링크 복사], [링크+제목 복사],
조회: 12069
글쓴 사람
정성태 (techsharer at outlook.com)
홈페이지
첨부 파일
 
(연관된 글이 2개 있습니다.)
(시리즈 글이 6개 있습니다.)
.NET Framework: 884. eBEST XingAPI의 C# 래퍼 버전 - XingAPINet Nuget 패키지
; https://www.sysnet.pe.kr/2/0/12134

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

.NET Framework: 893. eBEST C# XingAPI 래퍼 - 로그인 처리
; https://www.sysnet.pe.kr/2/0/12146

.NET Framework: 894. eBEST C# XingAPI 래퍼 - 연속 조회 처리 방법
; https://www.sysnet.pe.kr/2/0/12149

.NET Framework: 1996. C# XingAPI - 주식 종목에 따른 PBR, PER, ROE, ROA 구하는 방법(t3320, t8430 예제)
; https://www.sysnet.pe.kr/2/0/13034

.NET Framework: 2002. C# XingAPI - ACF 파일을 이용한 퀀트 종목 찾기(t1857)
; https://www.sysnet.pe.kr/2/0/13046




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)와 동일
    }
}




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

[연관 글]






[최초 등록일: ]
[최종 수정일: 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();
[guest]

[1]  2  3  4  5  6  7  8  9  10  11  12  13  14  15  ...
NoWriterDateCnt.TitleFile(s)
13647정성태6/16/2024228개발 환경 구성: 712. Windows - WSL 2의 네트워크 통신 방법 - 세 번째 이야기 (같은 IP를 공유하는 WSL 2 인스턴스)
13646정성태6/14/2024342오류 유형: 908. Process Explorer - "Error configuring dump resources: The system cannot find the file specified."
13645정성태6/13/2024544개발 환경 구성: 711. Visual Studio로 개발 시 기본 등록하는 dev tag 이미지로 Docker Desktop k8s에서 실행하는 방법
13644정성태6/12/2024569닷넷: 2265. C# - System.Text.Json의 기본적인 (한글 등에서의) escape 처리
13643정성태6/12/2024562오류 유형: 907. MySqlConnector 사용 시 System.IO.FileLoadException 오류
13642정성태6/11/2024615스크립트: 65. 파이썬 - asgi 버전(2, 3)에 따라 달라지는 uvicorn 호스팅
13641정성태6/11/2024879Linux: 71. Ubuntu 20.04를 22.04로 업데이트
13640정성태6/10/2024943Phone: 21. C# MAUI - Android 환경에서의 파일 다운로드(DownloadManager)
13639정성태6/8/2024897오류 유형: 906. C# MAUI - Android Emulator에서 "Waiting For Debugger"로 무한 대기
13638정성태6/8/20241002오류 유형: 905. C# MAUI - 추가한 layout XML 파일이 Resource.Layout 멤버로 나오지 않는 문제
13637정성태6/6/20241088Phone: 20. C# MAUI - 유튜브 동영상을 MediaElement로 재생하는 방법
13636정성태5/30/20241103닷넷: 2264. C# - 형식 인자로 인터페이스를 갖는 제네릭 타입으로의 형변환파일 다운로드1
13635정성태5/29/2024939Phone: 19. C# MAUI - 안드로이드 "Share" 대상으로 등록하는 방법
13634정성태5/24/20241189Phone: 18. C# MAUI - 안드로이드 플랫폼에서의 Activity 제어
13633정성태5/22/20241137스크립트: 64. 파이썬 - ASGI를 만족하는 최소한의 구현 코드
13632정성태5/20/20241239Phone: 17. C# MAUI - Android 내에 Web 서비스 호스팅
13631정성태5/19/20241244Phone: 16. C# MAUI - /Download 등의 공용 디렉터리에 접근하는 방법
13630정성태5/19/20241593닷넷: 2263. C# - Thread가 Task보다 더 빠르다는 어떤 예제(?)
13629정성태5/18/20241417개발 환경 구성: 710. Android - adb.exe를 이용한 파일 전송
13628정성태5/17/20241591개발 환경 구성: 709. Windows - WHPX(Windows Hypervisor Platform)를 이용한 Android Emulator 가속
13627정성태5/17/20241575오류 유형: 904. 파이썬 - UnicodeEncodeError: 'ascii' codec can't encode character '...' in position ...: ordinal not in range(128)
13626정성태5/15/20241691Phone: 15. C# MAUI - MediaElement Source 경로 지정 방법파일 다운로드1
13625정성태5/14/20241948닷넷: 2262. C# - Exception Filter 조건(when)을 갖는 catch 절의 IL 구조
13624정성태5/12/20241983Phone: 14. C# - MAUI에서 MediaElement 사용파일 다운로드1
13623정성태5/11/20242157닷넷: 2261. C# - 구글 OAuth의 JWT (JSON Web Tokens) 해석파일 다운로드1
[1]  2  3  4  5  6  7  8  9  10  11  12  13  14  15  ...