Guía de Instalación y Uso del SDK DataMesh

# Instalación directa desde el repositorio oficial
pip install git+https://github.com/datosbolivia/datamesh.git#subdirectory=bindings/python

npm install @datosbolivia/datamesh-client

pnpm add @datosbolivia/datamesh-client

# Descarga directa del binario compilado (Linux x86_64)
curl -L https://github.com/datosbolivia/datamesh/releases/latest/download/datamesh-linux-amd64 -o /usr/local/bin/datamesh
chmod +x /usr/local/bin/datamesh

import datamesh as dm

# Descubrir datasets disponibles en la federación soberana
catalogo = dm.discover()

for nodo in catalogo.nodes:
    print(f"[{nodo.category}] {nodo.slug} - {nodo.title}")
    for recurso in nodo.resources:
        print(f"   -> {recurso.triad} ({recurso.format})")

import datamesh as dm

# Consulta analítica con agregación y ordenamiento
query = """
SELECT 
    departamento, 
    COUNT(*) AS total_entidades
FROM 'bolivia:financial_entities:financial_entities_places'
WHERE departamento IS NOT NULL
GROUP BY departamento
ORDER BY total_entidades DESC
LIMIT 5;
"""

resultado = dm.sql(query)
print(resultado)

import datamesh as dm

# A DataFrame de Pandas
df = dm.sql("SELECT * FROM 'bolivia:air_quality:air_quality_compilaci_n_de_datos_de_calidad_del_aire_de_bolivia' LIMIT 100").to_df()
print(df.describe())

# A Polars DataFrame
import polars as pl
pl_df = pl.from_arrow(dm.sql("SELECT * FROM 'bolivia:oil_stations:oil_stations_stations'").to_arrow())
print(pl_df.head())

import { datamesh, DataMeshClient } from '@datosbolivia/datamesh-client';

async function main() {
  // 1. Descubrir recursos disponibles
  const catalog = await datamesh.discover();
  console.log(`Datasets indexados: ${catalog.entries.length}`);

  // 2. Ejecutar consulta sobre una tríada específica
  const records = await datamesh.query({
    resource_uri: 'bolivia:financial_entities:financial_entities_places',
    limit: 10,
    filters: {
      departamento: 'La Paz'
    }
  });

  console.log('Registros recuperados:', records);
}

main().catch(console.error);

\`\`\`ojs
const data = await datamesh.query({
  resource_uri: "financial_entities:financial_entities_places",
  limit: 200
});

return Plot.plot({
  title: "Puntos de Atención Financiera por Departamento",
  marks: [
    Plot.barX(data.rows, Plot.groupY({ x: "count" }, {
      y: (d) => d[data.columns.indexOf("departamento")],
      fill: "var(--color-primary, #0284c7)",
      sort: { y: "-x" }
    }))
  ]
});
\`\`\`

import { DataMeshMcpClient } from './src/lib/mcp';

const mcpClient = new DataMeshMcpClient({
  serverUrl: 'http://localhost:8000/mcp' // Configurable vía PUBLIC_DATAMESH_MCP_URL
});

// Ejecuta SQL remoto en el servidor DuckDB del backend
const resultado = await mcpClient.querySql(`
  SELECT departamento, COUNT(*) AS total
  FROM 'anh-dispatch-reports:anh_dispatch'
  GROUP BY departamento
  ORDER BY total DESC;
`);
console.log(resultado.rows);

# Verificar versión y estado del motor
datamesh --version

# Listar todos los catálogos y datasets federados
datamesh discover

# Inspeccionar el esquema de un dataset específico
datamesh inspect "bolivia:air_quality:air_quality_compilaci_n_de_datos_de_calidad_del_aire_de_bolivia"

# Ejecutar una consulta SQL directa
datamesh sql "SELECT lugar_nombre, ROUND(AVG(valor_ica), 1) AS promedio_ica FROM 'bolivia:air_quality:air_quality_compilaci_n_de_datos_de_calidad_del_aire_de_bolivia' GROUP BY lugar_nombre ORDER BY promedio_ica DESC LIMIT 5"

# Exportar el resultado a formato JSON o CSV
datamesh sql "SELECT * FROM 'bolivia:agetic_data:estadisticas_ciudadania_digital'" --format=json > ciudadania.json

# Iniciar el servidor unificado HTTP REST, Proxy CORS y MCP (datamesh serve)
datamesh serve --port 8000 --host 0.0.0.0

# Modo Stdio tradicional (para Claude Desktop / Cursor CLI)
datamesh mcp-serve

# Modo HTTP / Daemon de red con proxy CORS integrado
datamesh serve --port 8000

{
  "mcpServers": {
    "datamesh": {
      "command": "datamesh",
      "args": ["mcp-serve"],
      "env": {
        "DATAMESH_CATALOG_URL": "https://datosbolivia.github.io/llms.txt"
      }
    }
  }
}