REST API & WebSocket

import requests

API_KEY = "ba_live_xxxx_xxxx"
BASE = "https://bandaralert.com/api/v1"
headers = {"X-API-Key": API_KEY}

# 1. BASS scores. This group wraps its payload as {"data": [...], "meta": {...}}
resp = requests.get(f"{BASE}/signals/broker-accumulation", headers=headers)
signals = resp.json()["data"]

for s in signals[:5]:
    # The field is signal_confidence, not confidence.
    print(f"{s['ticker']}: BASS={s['bass_score']:.0f}, {s['signal_confidence']}")

# 2. OHLCV for BBCA (30 days) -> {"ticker", "interval", "data": [...]}
ohlcv = requests.get(f"{BASE}/data/ohlcv/BBCA?days=30", headers=headers).json()
print(f"BBCA: {len(ohlcv['data'])} data points")

# 3. Market regime. The state field is current_state, and its values are
# foreign_inflow_bull | domestic_rotation_neutral | risk_off_bear.
# Probabilities are an object, one float per state, not a single number.
regime = requests.get(f"{BASE}/signals/market-regime", headers=headers).json()
probs = regime["probabilities"]
print(f"Regime: {regime['current_state']} for {regime['days_in_state']} days")
print(f"  bull={probs['bull']:.0%} neutral={probs['neutral']:.0%} bear={probs['bear']:.0%}")

# 4. Ekspor seluruh papan ke Excel. SATU permintaan, sekitar 830 emiten yang
#    punya data broker EOD. Ini jalur termurah; jangan looping per emiten kalau
#    yang Anda butuhkan ringkasannya.
import pandas as pd

rows = requests.get(
    f"{BASE}/signals/broker-accumulation",
    params={"min_score": 0, "limit": 1000},
    headers=headers, timeout=60,
).json()["data"]

pd.DataFrame(rows).to_excel("bandarmologi_eod.xlsx", index=False)

# 5. Rincian PER KODE BROKER, satu emiten per permintaan. Beri jeda: di tepi ada
#    batas 10 permintaan per detik per alamat IP, terpisah dari kuota per-jam
#    akun Anda. Menyapu ~830 emiten memakan sekitar dua menit.
import time

detail = []
for r in rows:
    d = requests.get(f"{BASE}/dsh/broker-summary/{r['ticker']}",
                     headers=headers, timeout=30)
    if d.status_code == 429:
        time.sleep(int(d.headers.get("Retry-After", 5)))
        continue
    detail.append({"ticker": r["ticker"], **d.json()})
    time.sleep(0.15)