한국 금융 데이터 API 생태계 총정리

┌─────────────────────────────────────────────────────────┐
│                    정부/규제 기관                          │
│  금융위원회 ─── 금융감독원 ─── 금융보안원 ─── 금융결제원     │
└───────────┬──────────────────┬──────────────────┬────────┘
            │                  │                  │
    ┌───────▼───────┐  ┌──────▼──────┐  ┌───────▼───────┐
    │  마이데이터 API │  │ 오픈뱅킹 API │  │ 증권사 Open API│
    │  (사업자 허가)  │  │ (사업자 등록) │  │ (개인 사용 가능)│
    └───────┬───────┘  └──────┬──────┘  └───────┬───────┘
            │                  │                  │
    ┌───────▼───────┐  ┌──────▼──────┐  ┌───────▼───────┐
    │ 토스, 뱅크샐러드│  │ 핀테크 앱   │  │ 개인 투자자    │
    │ 카카오페이 등  │  │ 페이 서비스  │  │ 알고리즘 트레이더│
    └───────────────┘  └─────────────┘  └───────────────┘
            │
    ┌───────▼───────┐
    │ CODEF (중개)   │ ← 스크래핑+API 하이브리드
    └───────────────┘

# 공시목록 조회 (핵심)
GET /api/list.json?crtfc_key={key}&corp_code=00126380&bgn_de=20260201
 
# 기업개황 조회
GET /api/company.json?crtfc_key={key}&corp_code=00126380
 
# 고유번호 다운로드 (종목코드 매핑)
GET /api/corpCode.xml?crtfc_key={key}
 
# 단일회사 재무제표
GET /api/fnlttSinglAcnt.json?crtfc_key={key}&corp_code=00126380

import aiohttp
 
DART_BASE_URL = "https://opendart.fss.or.kr/api"
 
 
async def fetch_dart_disclosures(
    api_key: str,
    corp_code: str | None = None,
    bgn_de: str = "",
    end_de: str = "",
    pblntf_ty: str = "",
    page_count: int = 100,
) -> dict:
    """DART 공시목록 조회."""
    params = {
        "crtfc_key": api_key,
        "page_count": str(page_count),
    }
    if corp_code:
        params["corp_code"] = corp_code
    if bgn_de:
        params["bgn_de"] = bgn_de
    if end_de:
        params["end_de"] = end_de
    if pblntf_ty:
        params["pblntf_ty"] = pblntf_ty
 
    async with aiohttp.ClientSession() as session:
        async with session.get(
            f"{DART_BASE_URL}/list.json", params=params
        ) as resp:
            resp.raise_for_status()
            data = await resp.json()
            if data.get("status") != "000":
                raise Exception(f"DART API Error: {data.get('message')}")
            return data

GET /api/v1/company-news?symbol=AAPL&from=2026-02-01&to=2026-02-19&token={key}

GET /api/v1/news-sentiment?symbol=AAPL&token={key}

{
  "symbol": "AAPL",
  "companyNewsScore": 0.75,
  "sectorAverageNewsScore": 0.52,
  "sentiment": {
    "bullishPercent": 0.82,
    "bearishPercent": 0.18
  },
  "buzz": {
    "articlesInLastWeek": 45,
    "weeklyAverage": 30.5,
    "buzz": 1.47
  }
}

import aiohttp
from datetime import datetime, timedelta
 
FINNHUB_BASE_URL = "https://finnhub.io/api/v1"
 
 
async def fetch_company_news(
    api_key: str,
    symbol: str,
    days: int = 7,
) -> list[dict]:
    """Finnhub 종목별 뉴스 조회."""
    end_date = datetime.now().strftime("%Y-%m-%d")
    start_date = (datetime.now() - timedelta(days=days)).strftime("%Y-%m-%d")
 
    async with aiohttp.ClientSession() as session:
        async with session.get(
            f"{FINNHUB_BASE_URL}/company-news",
            params={
                "symbol": symbol,
                "from": start_date,
                "to": end_date,
                "token": api_key,
            },
        ) as resp:
            resp.raise_for_status()
            return await resp.json()
 
 
async def fetch_news_sentiment(api_key: str, symbol: str) -> dict:
    """Finnhub 뉴스 감성분석 조회."""
    async with aiohttp.ClientSession() as session:
        async with session.get(
            f"{FINNHUB_BASE_URL}/news-sentiment",
            params={"symbol": symbol, "token": api_key},
        ) as resp:
            resp.raise_for_status()
            return await resp.json()

import aiohttp
from bs4 import BeautifulSoup
 
 
async def fetch_naver_stock_news(stock_code: str, page: int = 1) -> list[dict]:
    """네이버 증권 종목뉴스 크롤링."""
    url = (
        f"https://finance.naver.com/item/news_news.naver"
        f"?code={stock_code}&page={page}"
    )
    headers = {
        "User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) "
                       "AppleWebKit/537.36",
    }
 
    async with aiohttp.ClientSession() as session:
        async with session.get(url, headers=headers) as resp:
            html = await resp.text()
 
    soup = BeautifulSoup(html, "html.parser")
    results = []
    rows = soup.select("table.type2 tbody tr")
    for row in rows:
        title_td = row.select_one("td.title")
        date_td = row.select_one("td.date")
        if title_td and title_td.a:
            results.append({
                "title": title_td.a.get_text(strip=True),
                "url": "https://finance.naver.com" + title_td.a["href"],
                "date": date_td.get_text(strip=True) if date_td else "",
            })
    return results

async def get_domestic_volume_ranking(
    client: "KISClient",
    market: str = "0000",  # 0000:전체, 0001:코스피, 1001:코스닥
    sort_by: str = "0",    # 0:평균거래량, 3:거래금액순
) -> list[dict]:
    """국내주식 거래량순위 조회."""
    data = await client.get(
        path="/uapi/domestic-stock/v1/quotations/volume-rank",
        tr_id="FHPST01710000",
        params={
            "FID_COND_MRKT_DIV_CODE": "J",
            "FID_COND_SCR_DIV_CODE": "20171",
            "FID_INPUT_ISCD": market,
            "FID_DIV_CLS_CODE": "0",
            "FID_BLNG_CLS_CODE": sort_by,
            "FID_TRGT_CLS_CODE": "111111111",
            "FID_TRGT_EXLS_CLS_CODE": "000000",
            "FID_INPUT_PRICE_1": "",
            "FID_INPUT_PRICE_2": "",
            "FID_VOL_CNT": "",
            "FID_INPUT_DATE_1": "",
        },
    )
    items = data.get("output", [])
    return [
        {
            "rank": int(item.get("data_rank", 0)),
            "code": item.get("mksc_shrn_iscd", "").strip(),
            "name": item.get("hts_kor_isnm", ""),
            "price": int(item.get("stck_prpr", 0)),
            "change_rate": float(item.get("prdy_ctrt", 0)),
            "volume": int(item.get("acml_vol", 0)),
            "trade_amount": int(item.get("acml_tr_pbmn", 0)),
        }
        for item in items
        if item.get("mksc_shrn_iscd", "").strip()
    ]

from easycodefpy import Codef
 
codef = Codef()
codef.public_key = "YOUR_PUBLIC_KEY"
 
# 은행 보유 계좌 조회
result = codef.request_product(
    "/v1/kr/bank/p/account/account-list",
    service_type=0,
    param={
        "organization": "0004",  # KB국민은행
        "loginType": "0",
        "id": "user_id",
        "password": "encrypted_password"
    }
)

class BrokerInterface(ABC):
    @abstractmethod
    async def get_balance(self) -> Balance: ...
 
    @abstractmethod
    async def get_positions(self) -> list[Position]: ...
 
    @abstractmethod
    async def place_order(self, order: Order) -> OrderResult: ...
 
 
class KISBroker(BrokerInterface): ...
class KiwoomBroker(BrokerInterface): ...
class LSBroker(BrokerInterface): ...
 
 
class BrokerAggregator:
    """여러 증권사 계좌 통합 조회."""
 
    def __init__(self, brokers: list[BrokerInterface]):
        self.brokers = brokers
 
    async def get_total_portfolio(self) -> Portfolio:
        results = await asyncio.gather(
            *[b.get_positions() for b in self.brokers]
        )
        return self._merge_positions(results)

┌─────────────────────────────────────────────────────┐
│                  Data Collector                      │
├─────────────────────────────────────────────────────┤
│                                                      │
│  [10분 주기]                                         │
│  ├── KIS 거래량순위 (국내)                            │
│  └── KIS 거래량순위 (해외)                            │
│                                                      │
│  [5분 주기 - 장중]                                    │
│  ├── DART 공시목록                                    │
│  └── Finnhub Company News                           │
│                                                      │
│  [1시간 주기]                                        │
│  ├── Finnhub News Sentiment                         │
│  └── 네이버 증권 뉴스                                 │
│                                                      │
│  [이벤트 트리거]                                      │
│  └── 거래량 급증 종목 감지 시                          │
│      ├── DART 해당 종목 공시 조회                     │
│      ├── Finnhub 해당 종목 뉴스 + 감성분석            │
│      └── 네이버 해당 종목 뉴스 크롤링                  │
│                                                      │
└─────────────────────────────────────────────────────┘