Giao dịch thuật toán Bitcoin trên Coinbase với Tín hiệu Vĩ mô của FXMacroData

Tại sao dữ liệu vĩ mô thúc đẩy Bitcoin

Bitcoin giao dịch ít giống như một cổ phiếu công nghệ và giống như tài sản vĩ mô hơn. Nó không trả cổ tức, không báo cáo lợi nhuận và không có mô hình dòng tiền để neo giá trị của nó. Thay vào đó, BTC di chuyển với điều kiện thanh khoản toàn cầu, kỳ vọng lãi suất thực và sức mạnh đồng đô la cùng các lực thúc đẩy EUR / USD và AUD / JPY. Điều đó có nghĩa là bộ công cụ vĩ mô được xây dựng cho các nhà giao dịch FX áp dụng trực tiếp cho Bitcoin.

Khi Fed nới lỏng, thanh khoản đô la tràn ngập thị trường rủi ro và BTC có xu hướng dẫn đầu. Khi CPI bất ngờ tăng, các câu chuyện hạ giá tiền tệ đẩy vốn vào tài sản cứng. Khi lạm phát thâm nhập tăng, lợi suất thực tế bị nén và vàng tăng cùng với BTC. Mỗi tín hiệu này đều có thể quan sát được trước thông qua các điểm cuối chỉ số của FXMacroData có dấu thời gian đến giây và có sẵn qua một API REST sạch.

Hướng dẫn này xây dựng một robot giao dịch thuật toán dựa trên tín hiệu vĩ mô cho BTC-USD trên Coinbase Advanced Trade. Đến cuối bạn sẽ có một chiến lược Python hoạt động:

• Kéo dữ liệu tỷ lệ chính sách USD, lạm phát, lạm dụng đạt mức cân bằng và vàng từ FXMacroData
• Kết hợp chúng thành một điểm tổng hợp về chế độ vĩ mô
• Lên lịch thực thi xung quanh các bản phát hành macro có tác động cao thông qua lịch phát hành FXMacroData
• Gửi lệnh thị trường BTC-USD trên Coinbase bằng cách sử dụng chính thức coinbase-advanced-py SDK

Điều kiện tiên quyết

Trước khi bắt đầu, hãy chắc chắn rằng bạn đã chuẩn bị những thứ sau:

• Python 3.10+ tất cả các đoạn trích sử dụng cú pháp đánh máy hiện đại
• FXMacroData API đăng ký tại /đăng ký và lấy chìa khóa của bạn từ bảng điều khiển tài khoản
• Tài khoản Coinbase Advanced Trade với một số dư USD tạo ra một Cloud API Trading Key (tên khóa API + khóa riêng EC) trong Nền tảng nhà phát triển Console với Thương mại quyền được kích hoạt
• Các gói Python requests coinbase-advanced-py pandas schedule

pip install requests coinbase-advanced-py pandas schedule

Lưu trữ thông tin đăng nhập của bạn như biến môi trường không bao giờ mã hóa bí mật trong các tập tin nguồn:

export FXMACRO_API_KEY="YOUR_FXMACRODATA_KEY"
export COINBASE_API_KEY_NAME="organizations/ORG_ID/apiKeys/KEY_ID"
export COINBASE_PRIVATE_KEY="-----BEGIN EC PRIVATE KEY-----
MHQCAQEEIBs...
-----END EC PRIVATE KEY-----"

Bước 1: Nhập tín hiệu macro từ FXMacroData

Bốn chuỗi vĩ mô neo mô hình chế độ BTC: Lãi suất chính sách USD lạm phát CPI, Tỷ lệ lạm phát mức cân bằng 10 năm, và giá mặt hàng vàngCùng nhau, họ mô tả môi trường thanh khoản, chế độ lạm phát và tình trạng nhu cầu tài sản cứng.

import os
import requests

BASE_URL = "https://fxmacrodata.com/api/v1"
FXMACRO_KEY = os.environ["FXMACRO_API_KEY"]


def get_series(path: str, start: str = "2024-01-01") -> list[dict]:
    """Fetch a time-series from FXMacroData."""
    resp = requests.get(
        f"{BASE_URL}{path}",
        params={"api_key": FXMACRO_KEY, "start": start},
        timeout=10,
    )
    resp.raise_for_status()
    return resp.json()["data"]


# Macro inputs
policy_rate   = get_series("/announcements/usd/policy_rate")
cpi           = get_series("/announcements/usd/inflation")
breakeven_10y = get_series("/announcements/usd/breakeven_inflation_rate")
gold          = get_series("/commodities/gold")

# data[0] is always the most recent reading
print(f"Policy rate (latest): {policy_rate[0]['val']}%")
print(f"CPI (latest):          {cpi[0]['val']}%")
print(f"10Y breakeven:         {breakeven_10y[0]['val']}%")
print(f"Gold spot:             ${gold[0]['val']:.2f}")

Mỗi điểm cuối trả về dữ liệu được sắp xếp gần đây nhất trước. val giữ hình ảnh tiêu đề và announcement_datetime mang dấu thời gian phát hành cấp hai hữu ích cho việc lập lịch trình được đề cập trong Bước 4. val là giá mặt bằng.

Bước 2: Xây dựng điểm số tổng hợp

Thay vì phản ứng với một chỉ số duy nhất, điểm tổng hợp tổng hợp tất cả bốn tín hiệu thành một số hướng giữa -1 (rủi ro, BTC giảm) và +1 (rối loạn, BTC tăng).

def macro_score(
    policy_rate_pct: float,
    cpi_pct: float,
    breakeven_pct: float,
    gold_usd: float,
    *,
    gold_baseline: float = 1900.0,
) -> float:
    """
    Returns a composite macro score in [-1, +1].

    Positive = risk-on / BTC bullish environment.
    Negative = risk-off / BTC bearish environment.
    """
    score = 0.0

    # ── Policy rate regime (weight 0.35) ──────────────────────────────
    # Below 4.5% = accommodative → bullish; above 5.5% = restrictive → bearish
    if policy_rate_pct < 4.5:
        score += 0.35
    elif policy_rate_pct <= 5.5:
        score += 0.35 * (5.5 - policy_rate_pct) / 1.0
    else:
        score -= 0.20

    # ── Inflation regime (weight 0.25) ────────────────────────────────
    # 2–4% moderate inflation → neutral/slightly bullish
    # >6% high inflation → debasement narrative → bullish
    # <1.5% deflationary risk → bearish
    if cpi_pct > 6.0:
        score += 0.25
    elif cpi_pct >= 2.0:
        score += 0.10
    else:
        score -= 0.15

    # ── Breakeven inflation (weight 0.20) ─────────────────────────────
    # Rising breakevens signal re-anchoring inflation expectations → bullish
    if breakeven_pct >= 2.5:
        score += 0.20
    elif breakeven_pct >= 2.0:
        score += 0.10
    else:
        score -= 0.10

    # ── Gold trend (weight 0.20) ──────────────────────────────────────
    # Gold above baseline confirms hard-asset demand → bullish
    gold_ratio = (gold_usd - gold_baseline) / gold_baseline
    score += 0.20 * max(-1.0, min(1.0, gold_ratio * 5))

    return round(max(-1.0, min(1.0, score)), 4)


score = macro_score(
    policy_rate_pct=policy_rate[0]["val"],
    cpi_pct=cpi[0]["val"],
    breakeven_pct=breakeven_10y[0]["val"],
    gold_usd=gold[0]["val"],
)
print(f"Composite macro score: {score:+.4f}")
# e.g. → +0.6000  (bullish regime)

Bước 3: Kết nối với Coinbase Advanced Trade API

Người quan chức. coinbase-advanced-py thư viện bao bọc API REST của Coinbase và xử lý xác thực JWT tự động. RESTClient sử dụng tên Cloud API Trading Key của bạn và khóa riêng EC liên quan.

import os
import uuid
from coinbase.rest import RESTClient

CB_KEY_NAME    = os.environ["COINBASE_API_KEY_NAME"]
CB_PRIVATE_KEY = os.environ["COINBASE_PRIVATE_KEY"]

client = RESTClient(api_key=CB_KEY_NAME, api_secret=CB_PRIVATE_KEY)

# Verify connectivity and fetch current BTC-USD price
product = client.get_best_bid_ask(product_ids=["BTC-USD"])
bids = product["pricebooks"][0]["bids"]
asks = product["pricebooks"][0]["asks"]
btc_price = (float(bids[0]["price"]) + float(asks[0]["price"])) / 2
print(f"BTC-USD mid-price: ${btc_price:,.2f}")

# Available USD balance
accounts = client.get_accounts()
usd_balance = 0.0
btc_balance = 0.0
for acct in accounts["accounts"]:
    if acct["currency"] == "USD":
        usd_balance = float(acct["available_balance"]["value"])
    if acct["currency"] == "BTC":
        btc_balance = float(acct["available_balance"]["value"])

print(f"Available USD: ${usd_balance:,.2f}")
print(f"Available BTC: {btc_balance:.6f}")

Bước 4: Lên lịch xung quanh các sự kiện phát hành macro

Một trong những tính năng mạnh mẽ nhất của FXMacroData cho giao dịch algo là điểm cuối lịch phát hành. Thay vì thăm dò trên một bộ đếm thời gian cố định, bạn truy vấn thời gian phát hành chính xác được lên kế hoạch cho bất kỳ chỉ số nào và kích hoạt việc làm mới tín hiệu của bạn chính xác khi xuất bản dữ liệu mới.

import datetime
import schedule
import time


def get_next_release(currency: str, indicator: str) -> datetime.datetime | None:
    """
    Returns the next scheduled release datetime for an indicator.
    The calendar endpoint returns upcoming events in ascending date order.
    """
    resp = requests.get(
        f"{BASE_URL}/calendar/{currency}",
        params={"api_key": FXMACRO_KEY},
        timeout=10,
    )
    resp.raise_for_status()
    events = resp.json().get("data", [])

    now_utc = datetime.datetime.now(tz=datetime.timezone.utc)
    for event in events:
        if event.get("indicator") != indicator:
            continue
        release_str = event.get("release_datetime") or event.get("date")
        if not release_str:
            continue
        release_dt = datetime.datetime.fromisoformat(
            release_str.replace("Z", "+00:00")
        )
        if release_dt > now_utc:
            return release_dt
    return None


# Example: find the next FOMC policy rate decision
next_fomc = get_next_release("usd", "policy_rate")
if next_fomc:
    delta = next_fomc - datetime.datetime.now(tz=datetime.timezone.utc)
    print(f"Next FOMC: {next_fomc.isoformat()}  ({delta.days}d {delta.seconds // 3600}h away)")

# Example: find the next CPI print
next_cpi = get_next_release("usd", "inflation")
if next_cpi:
    print(f"Next CPI:  {next_cpi.isoformat()}")

Với thời gian chính xác phát hành, bạn có thể lên lịch cập nhật tín hiệu sau khi phát hành cho phép phản ứng giá ban đầu giải quyết trước khi đánh giá lại và giao dịch:

def on_macro_release():
    """Called shortly after a scheduled macro release fires."""
    print("Macro release detected — refreshing signals...")
    run_strategy()


def schedule_next_release(currency: str, indicator: str, delay_seconds: int = 90):
    """
    Schedules the strategy to run 'delay_seconds' after the next release.
    A 90-second delay lets the initial market reaction absorb before entry.
    """
    release_dt = get_next_release(currency, indicator)
    if not release_dt:
        return

    fire_at = release_dt + datetime.timedelta(seconds=delay_seconds)
    fire_str = fire_at.strftime("%H:%M:%S")
    schedule.every().day.at(fire_str).do(on_macro_release).tag(
        f"{currency}_{indicator}"
    )
    print(f"Scheduled refresh at {fire_str} UTC after {currency.upper()} {indicator}")


schedule_next_release("usd", "policy_rate", delay_seconds=90)
schedule_next_release("usd", "inflation", delay_seconds=60)

Bước 5: Định giá và gửi lệnh trên Coinbase

Các lệnh giao dịch nâng cao của Coinbase hoạt động khác với Binance: mua lệnh chỉ định một quote_size (đồng tiền USD để chi tiêu), trong khi bán lệnh chỉ định một base_size (Tổng BTC để bán). Chức năng kích thước bên dưới quy mô phân bổ USD với kích thước tuyệt đối của điểm số macro niềm tin cao hơn đòi hỏi phân bổ lớn hơn, giới hạn ở mức tối đa có thể cấu hình.

import math


def compute_usd_allocation(
    score: float,
    usd_balance: float,
    max_position_pct: float = 0.20,
    min_threshold: float = 0.30,
) -> float:
    """
    Returns the USD amount to deploy for a BUY order.
    Scales between 0 and max_position_pct of available USD balance.
    Returns 0.0 if |score| < min_threshold (noise-filtered).
    Minimum order size on Coinbase Advanced Trade is $1 USD.
    """
    if abs(score) < min_threshold:
        return 0.0
    conviction = (abs(score) - min_threshold) / (1.0 - min_threshold)
    usd_to_trade = usd_balance * max_position_pct * conviction
    return max(1.0, round(usd_to_trade, 2))


def place_buy(usd_amount: float) -> dict | None:
    """Submit a market BUY order for a given USD amount."""
    if usd_amount <= 0:
        print("USD amount zero — no buy order placed.")
        return None
    order_id = str(uuid.uuid4())
    try:
        result = client.market_order_buy(
            client_order_id=order_id,
            product_id="BTC-USD",
            quote_size=str(usd_amount),
        )
        print(f"BUY order submitted: ${usd_amount:.2f} USD  (order_id={order_id})")
        return result
    except Exception as exc:
        print(f"Coinbase buy error: {exc}")
        return None


def place_sell(btc_amount: float) -> dict | None:
    """Submit a market SELL order for a given BTC amount."""
    # Minimum BTC lot size on Coinbase Advanced Trade is 0.000001 BTC
    btc_amount = math.floor(btc_amount * 1_000_000) / 1_000_000
    if btc_amount <= 0:
        print("BTC amount zero — no sell order placed.")
        return None
    order_id = str(uuid.uuid4())
    try:
        result = client.market_order_sell(
            client_order_id=order_id,
            product_id="BTC-USD",
            base_size=str(btc_amount),
        )
        print(f"SELL order submitted: {btc_amount:.6f} BTC  (order_id={order_id})")
        return result
    except Exception as exc:
        print(f"Coinbase sell error: {exc}")
        return None

Bước 6: Lắp ráp toàn bộ vòng lặp chiến lược

Bây giờ hãy kết hợp tất cả các mảnh ghép lại thành một. run_strategy() Trong mỗi cuộc gọi, nó lấy dữ liệu macro mới, tính toán lại điểm số, phát hiện thay đổi chế độ và nhập hoặc thoát theo đó.

import json
import pathlib

STATE_FILE = pathlib.Path("coinbase_strategy_state.json")


def load_state() -> dict:
    if STATE_FILE.exists():
        return json.loads(STATE_FILE.read_text())
    return {"position_btc": 0.0, "last_score": 0.0}


def save_state(state: dict) -> None:
    STATE_FILE.write_text(json.dumps(state, indent=2))


def run_strategy() -> None:
    state = load_state()

    # ── 1. Refresh macro data ──────────────────────────────────────────
    policy_rate_val = get_series("/announcements/usd/policy_rate")[0]["val"]
    cpi_val         = get_series("/announcements/usd/inflation")[0]["val"]
    breakeven_val   = get_series("/announcements/usd/breakeven_inflation_rate")[0]["val"]
    gold_val        = get_series("/commodities/gold")[0]["val"]

    # ── 2. Compute macro score ─────────────────────────────────────────
    score = macro_score(policy_rate_val, cpi_val, breakeven_val, gold_val)
    prev  = state["last_score"]
    print(f"Macro score: {score:+.4f}  (prev: {prev:+.4f})")

    # ── 3. Fetch current Coinbase balances ─────────────────────────────
    accounts  = client.get_accounts()
    usd_avail = 0.0
    btc_avail = 0.0
    for acct in accounts["accounts"]:
        if acct["currency"] == "USD":
            usd_avail = float(acct["available_balance"]["value"])
        if acct["currency"] == "BTC":
            btc_avail = float(acct["available_balance"]["value"])

    # ── 4. Regime change logic ─────────────────────────────────────────
    is_bullish = score >= 0.30
    was_bullish = prev >= 0.30
    is_neutral  = abs(score) < 0.30
    is_bearish  = score < -0.30

    if is_bullish and not was_bullish:
        # New bullish regime — enter long via USD allocation
        usd_to_use = compute_usd_allocation(score, usd_avail)
        place_buy(usd_to_use)

    elif is_neutral and was_bullish and btc_avail > 0.000001:
        # Regime turned neutral — exit position
        place_sell(btc_avail)
        print("Regime neutral — exiting BTC position.")

    elif is_bearish and btc_avail > 0.000001:
        # Hard exit on bearish macro signal
        place_sell(btc_avail)
        print("BEARISH regime — full exit.")

    # ── 5. Persist state ───────────────────────────────────────────────
    state["last_score"] = score
    state["position_btc"] = btc_avail
    save_state(state)


# ── Run once on startup, then on each scheduled macro release ──────────
run_strategy()

while True:
    schedule.run_pending()
    time.sleep(10)

Bước 7: Quản lý rủi ro và các cân nhắc hoạt động

Một chiến lược tín hiệu vĩ mô giao dịch ít thay đổi chế độ do FOMC, CPI và NFP in thường tạo ra 610 tín hiệu có thể thực hiện mỗi năm. Tần suất thấp đó là do thiết kế: bạn đang định vị cho các động thái hướng nhiều tuần, không phải tiếng ồn trong ngày. Nhưng mỗi vị trí mang lại rủi ro có ý nghĩa, vì vậy kiểm soát kỷ luật là điều cần thiết.

Tất cả các dấu thời gian từ FXMacroData bao gồm announcement_datetime trong các phản hồi chỉ số và thời gian phát hành từ điểm cuối lịch là UTC. Giữ logic lập lịch của bạn trong UTC trong suốt và chuyển đổi chỉ cho mục đích hiển thị. Điều này loại bỏ sự mơ hồ về tiết kiệm ánh sáng ban ngày xung quanh các bản phát hành dữ liệu của Hoa Kỳ, đây là một nguồn phổ biến của lỗi lập lịch.

Mở rộng chiến lược

Khung là mô-đun. Một số phần mở rộng tự nhiên đáng được khám phá tiếp theo:

• Thêm dữ liệu định vị COT Điểm cuối CFTC COT của FXMacroData cung cấp định vị đầu cơ hàng tuần trong hợp đồng tương lai USD. /cot/usd và thêm một thuật ngữ định vị ròng vào điểm số macro.
• Chỉ số thanh khoản đa tiền tệ kết hợp các tín hiệu macro EUR, JPY và GBP cùng với USD. Khi nhiều ngân hàng trung ương G10 đang giảm bớt đồng thời, điều kiện thanh khoản toàn cầu thuận lợi nhất cho các tài sản rủi ro như BTC.
• Tín hiệu tốc độ ngang nhau thay vì mức lạm phát mức độ ngang, sử dụng tỷ lệ thay đổi 4 tuần.
• Thực thi lệnh giới hạn thay thế market_order_buy/market_order_sell với limit_order_gtc_buy/limit_order_gtc_sell để tránh trả toàn bộ người nhận phân phối. lấy sổ đặt hàng hiện tại với client.get_best_bid_ask và ngồi một dấu chấm bên trong giá tốt nhất.
• Nhóm hóa lịch phát hành hỏi Lịch phát hành cho tất cả các sự kiện USD một tháng và xác định các cửa sổ nơi nhiều phát hành tác động cao tập hợp trong vòng 48 giờ.

Tóm lại

Bạn có một robot giao dịch Bitcoin dựa trên tín hiệu vĩ mô hoạt động được kết nối với Coinbase Advanced Trade. Chiến lược đọc tỷ lệ chính sách USD, CPI, lạm phát bình đẳng và vàng từ FXMacroData để xây dựng điểm số chế độ tổng hợp, lên lịch theo các sự kiện thông báo vĩ mô trong thế giới thực và gửi lệnh thị trường BTC-USD tỷ lệ thuận với niềm tin của chế độ.

Cách tiếp cận vĩ mô giao dịch ít thường xuyên và với sự thuyết phục cao chính xác là điều phân biệt các chiến lược dựa trên chế độ từ các hệ thống kỹ thuật theo đuổi tiếng ồn. Bước hợp lý tiếp theo là kiểm tra lại khuôn khổ này so với chuỗi thời gian FXMacroData lịch sử để hiệu chỉnh trọng số điểm và đo lường giảm trong nhiều chu kỳ Fed.