Lectura de Datos de la Cadena

Los servicios de Python leen el estado de Solana a través de JSON-RPC (getAccountInfo, getTokenAccountsByOwner, getSignaturesForAddress) y, para NFTs y activos comprimidos, la API Digital Asset Standard (DAS). Usa solana-py para el RPC principal y httpx para los endpoints HTTP de DAS en proveedores Agave 4.1.1.

Receta

Tarjeta de referencia rápida - lista para copiar y pegar.

from solders.pubkey import Pubkey
from solana.rpc.api import Client
 
client = Client("https://api.devnet.solana.com")
mint = Pubkey.from_string("<MINT_PUBKEY>")
 
info = client.get_account_info(mint)
print(info.value.lamports if info.value else "missing")
 
tokens = client.get_token_accounts_by_owner_json_parsed(
    Pubkey.from_string("<OWNER>"),
    {"mint": str(mint)},
)

Cuándo usar esto:

• Backends que sirven saldos y historial de carteras.
• Bots que monitorizan cambios de estado de cuentas entre envíos.
• Trabajos ETL que hidratan almacenes de datos a partir de cuentas en la cadena.
• Dashboards de NFT/cNFT a través de los métodos getAsset y de búsqueda de DAS.

Ejemplo de Trabajo

import asyncio
import httpx
from solders.pubkey import Pubkey
from solana.rpc.async_api import AsyncClient
 
RPC = "https://api.devnet.solana.com"
DAS = "https://devnet.helius-rpc.com/?api-key=<KEY>"  # proveedor con DAS habilitado
OWNER = Pubkey.from_string("<OWNER_PUBKEY>")
 
async def fetch_portfolio():
    async with AsyncClient(RPC) as client:
        sol = await client.get_balance(OWNER)
        sigs = await client.get_signatures_for_address(OWNER, limit=10)
 
        token_resp = await client.get_token_accounts_by_owner_json_parsed(
            OWNER,
            {"programId": "TokenkegQfeZyiNwAJbNbGKPFXCWuBvf9Ss623VQ5DA"},
        )
        tokens = token_resp.value
 
    async with httpx.AsyncClient() as http:
        das_resp = await http.post(
            DAS,
            json={
                "jsonrpc": "2.0",
                "id": 1,
                "method": "getAssetsByOwner",
                "params": {"ownerAddress": str(OWNER), "page": 1, "limit": 50},
            },
        )
        assets = das_resp.json()["result"]
 
    return {
        "lamports": sol.value,
        "recent_signatures": [s.signature for s in sigs.value],
        "spl_tokens": len(tokens),
        "das_assets": len(assets.get("items", [])),
    }
 
print(asyncio.run(fetch_portfolio()))

Lo que esto demuestra:

• El RPC principal lee el saldo de SOL, las firmas y las cuentas de tokens SPL.
• Las cuentas de tokens analizadas con JSON evitan la decodificación manual del diseño.
• DAS complementa el RPC para la agregación de metadatos de NFT/cNFT.
• La recopilación asíncrona de llamadas a proveedores vinculadas a E/S de manera eficiente.

Inmersión Profunda

Cómo Funciona

• Las cuentas almacenan lamports + bytes opacos; la interpretación depende del programa propietario.
• Las cuentas de tokens SPL utilizan un diseño bien conocido; el RPC jsonParsed devuelve campos estructurados.
• Las firmas para una dirección se paginan hacia atrás en el tiempo con el cursor before.
• DAS indexa activos digitales comprimidos y estándar; no es un reemplazo para todas las lecturas RPC.

Mapa de API de Lectura

Notas de Python

# Decodificar cuenta de Anchor con AnchorPy después de obtener datos brutos
# account = await program.account["MyState"].fetch(pubkey)
 
# Paginación de firmas
before = None
while True:
    batch = await client.get_signatures_for_address(addr, before=before, limit=1000)
    if not batch.value:
        break
    before = batch.value[-1].signature

Trampas

• getProgramAccounts sin filtros - descarga el estado completo del programa. Solución: memcmp en el discriminador; usar un indexador.
• Asumir DAS en cada URL RPC - el devnet público puede carecer de DAS. Solución: usar explícitamente un proveedor capaz de DAS.
• Confusión de codificación - base64 vs jsonParsed cambia la forma de la respuesta. Solución: elegir por llamada y documentar.
• Límites de tasa durante las copias de seguridad - los escaneos secuenciales activan 429s. Solución: limitar la velocidad, dividir por slot o exportar desde BigTable.
• Cuentas de tokens cerradas - las cuentas con saldo cero pueden omitirse. Solución: manejar listas vacías; rastrear los Mints por separado.

Alternativas

Preguntas Frecuentes

Relacionado

• solders y solana-py - Configuración del cliente RPC
• Análisis de Datos - Exportación a pandas/Polars
• La API DAS - Referencia de DAS
• Conceptos Básicos de RPC - Núcleo de JSON-RPC

Versiones de Stack: Esta página se escribió para Agave 4.1.1, Solana CLI 3.0.10, Anchor 0.32.1, anchor-lang 0.32.1, Rust 1.91.1, @solana/kit 7.0.0, Surfpool 0.12.0, y LiteSVM 0.6.x.