[ECOS API] 한국은행 경제통계 API 이용 (2) json

원래는 API 기본 값인 xml로 데이터를 처리하다가,

뒤늦게 json타입도 지원되는 걸 발견하고 환승하면서 코드를 class로 정리해서 모아두기로 했다.

 

주요 목적은 인증키와 STAT_CODE와 ITEM_CODE1, count 정보를 담은 객체를 만들어두고,

필요할 때마다 최근 데이터를 불러오는 함수 작성하기. 아래와 같은 모양이다.

setting = {
            'key': 'asdf'
            'dataType': 'json',
            'language': 'kr',
}  # 이쪽에 기본 정보를 정리해두고

corpBondAAm = Ecos(setting, STAT_CODE='060Y001', ITEM_CODE1='010300000', count=19)
print(corpBondAAm.getLatest()) # {'20201211': 2.215} 

corpBondBBBm = Ecos(setting, STAT_CODE='060Y001', ITEM_CODE1='01032000', count=20)
print(corpBondBBBm.getLatest()) # {'20201211': 8.626}

 

작성해야할 url 구문은 아래와 같다. 이중 채워야할 부분은 일자타입, 시작/종료일자.

http://ecos.bok.or.kr/api/StatisticSearch/인증키/json/kr/1/1/STAT_CODE/일자타입/시작일자/종료일자/ITEM_CODE1/

데이터는 1건씩만 받을 것이라 STAT_CODE 앞의 부분은 /1/1/로 채웠다.

시작/종료일자는 가장 최근 데이터가 언제인지를 알아야 채울 수 있다.

 

이 정보는 통계 세부항목 목록(StatisticItemList) 쪽에 url을 보내면 알 수 있다.

시장금리(일별)(060Y001) 데이터에 세부항목이 23건이 있고, 내가 찾고 싶은 회사채(3년,AA-)(010300000) 데이터는 그중 19번이다.

count 입력을 생략하도록 할까 하다가, 어차피 서비스 가능한 통계코드를 찾다보면 찾아야해서 그냥 입력하기로 했다.

http://ecos.bok.or.kr/api/StatisticItemList/인증키/json/kr/19/19/060Y001/

 

위 쿼리를 보내면 이런 데이터를 얻을 수 있다.

{
  "StatisticItemList": {
    "list_total_count": 23,
    "row": [
      {
        "END_TIME": "20201211",
        "DATA_CNT": 6633,
        "GRP_NAME": "항목선택",
        "CYCLE": "DD",
        "STAT_NAME": "4.1.1 시장금리(일별)",
        "ITEM_NAME": "회사채(3년,AA-)",
        "GRP_CODE": "Group1",
        "STAT_CODE": "060Y001",
        "ITEM_CODE": "010300000",
        "START_TIME": "19950103",
        "P_ITEM_CODE": ""
      }
    ]
  }
}

이제 여기서jsondata['StatisticItemList']['row'][0]['END_TIME']값 20201211을

위의 시작/종료일자에 채워서 다시 보내면 된다.

 

그러면 아래와 같은 데이터를 얻을 수 있고, 값은 jsondata['StatisticSearch']['row'][0]['DATA_VALUE']로 접근하면 된다.

{
  "StatisticSearch": {
    "list_total_count": 1,
    "row": [
      {
        "UNIT_NAME": "연%",
        "STAT_NAME": "4.1.1 시장금리(일별)",
        "ITEM_CODE1": "010300000",
        "STAT_CODE": "060Y001",
        "ITEM_CODE2": " ",
        "ITEM_CODE3": " ",
        "ITEM_NAME1": "회사채(3년,AA-)",
        "ITEM_NAME2": " ",
        "DATA_VALUE": "2.215",
        "ITEM_NAME3": " ",
        "TIME": "20201211"
      }
    ]
  }
}

함수를 작성하면 이렇다.

 

import requests

class Ecos:
    def __init__(self, Key, STAT_CODE, ITEM_CODE1, count):
        # count: StatisticItemList에서 ITEM_CODE1이 STAT_CODE의 몇 번째 항목인지
        self.Key = Key
        self.STAT_CODE = STAT_CODE
        self.ITEM_CODE1 = ITEM_CODE1
        self.base = 'http://ecos.bok.or.kr/api/'
        self.count = count

    def getJSON(self, url):
        return requests.get(url).json()

    def getDate(self):  # 최근 일자 구하기
        url = self.base + 'StatisticItemList/' + self.Key \
              + '/json/kr/' + str(self.count) + '/' + str(self.count) \
              + '/' + self.STAT_CODE
        data = self.getJSON(url)
        return (data['StatisticItemList']['row'][0]['END_TIME'],
                data['StatisticItemList']['row'][0]['CYCLE'])

    def getLatest(self):  # 목표인 금리 데이터 구하기
        date, cycle = self.getDate()
        url = self.base + 'StatisticSearch/' + self.Key \
              + '/json/kr/1/1/' + self.STAT_CODE + '/' + cycle + '/' \
              + date + '/' + date + '/' + self.ITEM_CODE1
        data = self.getJSON(url)
        returnDict = {
            'date': date,
            'value': float(data['StatisticSearch']['row'][0]['DATA_VALUE'])
        }
        return returnDict

Key = ''

corpBondAAm = Ecos(Key, STAT_CODE='060Y001', ITEM_CODE1='010300000', count=19)
print(corpBondAAm.getLatest()) # {'date': '20201211', 'value': 2.215}
corpBondBBBm = Ecos(Key, STAT_CODE='060Y001', ITEM_CODE1='010320000', count=20)
print(corpBondBBBm.getLatest()) # {'date': '20201211', 'value': 8.626}

 

 

 

---

getLatest() 메소드 보충

 

20년 12월 15일 오후 4시 30분 경에 코드를 돌리다가 에러가 나는 것을 확인했다.

StatisticItemList 쪽 END_TIME은 '20201215'로 업데이트 되었는데,

StatisticSearch 쪽에는 아직 데이터가 추가되지 않아서 에러가 났다. 이 경우 값은 이렇게 반환된다.

{"RESULT":{"MESSAGE":"해당하는 데이터가 없습니다.","CODE":"INFO-200"}}

데이터는 4시 40분 경 업데이트 되었으니 정규 마켓타임이 아니라서 실제 불편함은 없을 것 같아서 간단히만 수정했다.

확인이 완료된 최근 일자를 validDate에 저장해두고 불러쓰는 형식으로 변경:

    def getLatest(self):  # 목표인 금리 데이터 구하기
        date, cycle = self.getDate()
        url = self.base + 'StatisticSearch/' + self.Key \
              + '/json/kr/1/1/' + self.STAT_CODE + '/' + cycle + '/' \
              + date + '/' + date + '/' + self.ITEM_CODE1
        data = self.getJSON(url)
        if "RESULT" in data:
            url = url.replace(date, self.validDate, 2)
            data = self.getJSON(url)
        returnDict = {
            'date': date,
            'value': float(data['StatisticSearch']['row'][0]['DATA_VALUE'])
        }
        self.validDate = date
        return returnDict