Từ con số không đến số liệu chạy trong code của bạn

import os, time, requests, pandas as pd

BASE = "https://api.dulieukinhte.com/v1"
H = {"Authorization": f"Bearer {os.environ['DLKT_API_KEY']}"}

def observations(series_id, **params):
    """Lấy hết các trang bằng con trỏ. Trả pd.Series đánh chỉ mục theo ngày."""
    rows, cursor = [], None
    while True:
        p = {**params, "limit": 10000}
        if cursor:
            p["cursor"] = cursor
        r = requests.get(f"{BASE}/series/{series_id}/observations",
                         headers=H, params=p, timeout=60)

        if r.status_code == 429:
            code = r.json()["error"]["code"]
            if code == "rate_limited":
                # "chậm lại" -> đợi rồi thử lại chính lượt này
                time.sleep(int(r.headers.get("Retry-After", 5)))
                continue
            # "hết tháng" -> thử lại chỉ tốn thêm, dừng hẳn
            raise RuntimeError(r.json()["error"]["message"])

        r.raise_for_status()
        j = r.json()
        rows += j["data"]["observations"]
        if not j["meta"]["hasMore"]:
            break
        cursor = j["meta"]["nextCursor"]

    df = pd.DataFrame(rows)
    df["date"] = pd.to_datetime(df["date"])
    return df.set_index("date")["value"]

# 'from' là từ khoá của Python nên phải truyền qua **{}
cpi = observations(8241, transform="yoy", **{"from": "2015-01-01"})
print(cpi.tail())

def many(ids, **params):
    """Tối đa 20 id mỗi lượt. Trả DataFrame dạng RỘNG: mỗi chuỗi một cột."""
    out = {}
    for i in range(0, len(ids), 20):
        chunk = ids[i:i + 20]
        r = requests.get(f"{BASE}/series/observations", headers=H, timeout=60,
                         params={**params, "ids": ",".join(map(str, chunk)), "limit": 5000})
        r.raise_for_status()
        j = r.json()

        # Chuỗi không tồn tại KHÔNG làm hỏng cả lượt — nó nằm ở meta.missing
        for m in j["meta"].get("missing", []):
            print(f"bỏ qua id không tồn tại: {m}")

        for s in j["data"]:
            # transform không áp được cho tần suất của chuỗi này -> bị bỏ qua,
            # 19 chuỗi còn lại vẫn về bình thường
            if s.get("skipped"):
                print(f"bỏ qua {s['id']} ({s['name']}): {s['reason']}")
                continue
            ser = pd.DataFrame(s["observations"])
            ser["date"] = pd.to_datetime(ser["date"])
            out[s["name"]] = ser.set_index("date")["value"]
    return pd.DataFrame(out)

df = many([8241, 8242, 8243, 8244], transform="yoy", **{"from": "2020-01-01"})
print(df.tail())

=IMPORTDATA("https://api.dulieukinhte.com/v1/series/8241/observations?format=csv&from=2015-01-01&api_key=dlkt_live_…")

https://api.dulieukinhte.com/v1/series/8241/observations?format=csv&from=2015-01-01&api_key=dlkt_live_…

# hồ sơ: sàn, ngành, có những loại báo cáo nào, dải giá đến đâu
curl -s -H "Authorization: Bearer $DLKT_API_KEY" "https://api.dulieukinhte.com/v1/companies/FPT"

# kết quả kinh doanh, theo quý, 12 kỳ gần nhất
curl -s -H "Authorization: Bearer $DLKT_API_KEY" \
  "https://api.dulieukinhte.com/v1/companies/FPT/financials?statementType=2&freq=quarter&limit=12"

fs = requests.get(f"{BASE}/companies/FPT/financials",
                  headers=H, params={"statementType": 2, "freq": "quarter", "limit": 12}
                  ).json()["data"]

names = {l["id"]: l["name"] for l in fs["lines"]}
df = (pd.DataFrame(fs["values"])
        .assign(line=lambda d: d["lineId"].map(names))
        .pivot(index="line", columns="period", values="value"))
print(df.head(20))

def prices(symbol, start="2020-01-01"):
    out, cur = [], start
    while True:
        r = requests.get(f"{BASE}/companies/{symbol}/prices", headers=H, timeout=60,
                         params={"from": cur, "order": "asc", "limit": 5000})
        r.raise_for_status()
        j = r.json()
        bars = j["data"]["bars"]
        if not bars:
            break
        out += bars
        if not j["meta"]["hasMore"]:
            break
        # trang sau bắt đầu từ ngày kế tiếp ngày cuối của trang này
        cur = (pd.Timestamp(bars[-1]["date"]) + pd.Timedelta(days=1)).strftime("%Y-%m-%d")

    df = pd.DataFrame(out).drop_duplicates("date")
    df["date"] = pd.to_datetime(df["date"])
    return df.set_index("date")

print(prices("FPT").tail())

import os, time, requests, pandas as pd
from datetime import datetime, timedelta, timezone

BASE = "https://api.dulieukinhte.com/v1"
H = {"Authorization": f"Bearer {os.environ['DLKT_API_KEY']}"}

def get(path, **params):
    """Một chỗ duy nhất xử lý lỗi cho mọi lượt gọi."""
    for attempt in range(5):
        r = requests.get(f"{BASE}{path}", headers=H, params=params, timeout=60)
        if r.status_code == 429:
            body = r.json()["error"]
            if body["code"] == "quota_exceeded":
                raise SystemExit(f"HẾT HẠN MỨC THÁNG: {body['message']}")
            time.sleep(int(r.headers.get("Retry-After", 5)))
            continue
        if r.status_code >= 500:
            time.sleep(2 ** attempt)   # lùi theo cấp số nhân
            continue
        if not r.ok:
            e = r.json()["error"]
            raise RuntimeError(f"{e['code']}: {e['message']} (requestId={e['requestId']})")
        return r.json()
    raise RuntimeError("thử lại 5 lần vẫn không xong")

# ── 1. Chuỗi nào đã đổi kể từ lần chạy trước? ───────────────────────────
since = (datetime.now(timezone.utc) - timedelta(days=1)).strftime("%Y-%m-%dT%H:%M:%SZ")
changed, page = [], 1
while True:
    j = get("/updates", since=since, page=page, perPage=500)
    changed += [u["seriesId"] for u in j["data"]]
    if not j["meta"]["hasMore"]:
        break
    page += 1

print(f"{len(changed)} chuỗi có số mới")

# ── 2. Kéo về, 20 chuỗi mỗi lượt ────────────────────────────────────────
frames = []
for i in range(0, len(changed), 20):
    j = get("/series/observations", ids=",".join(map(str, changed[i:i + 20])),
            limit=2000, **{"from": "2020-01-01"})
    for s in j["data"]:
        if s.get("skipped"):
            continue
        for o in s["observations"]:
            frames.append({"series_id": s["id"], "name": s["name"],
                           "date": o["date"], "value": o["value"]})

pd.DataFrame(frames).to_parquet("cap-nhat.parquet")
print(f"ghi {len(frames)} điểm")