Faculty at CMU (@cmudig) and researcher at @apple.
Public
Edited
Jul 26, 2024
duckdbWasmVersion = "1.28.1-dev106.0"
arrow = require("apache-arrow")
duckdb = import(
`https://cdn.jsdelivr.net/npm/@duckdb/duckdb-wasm@${duckdbWasmVersion}/+esm`
)
bundles = duckdb.getJsDelivrBundles()
bundle = duckdb.selectBundle(bundles)
async function makeDB() {
const logger = new duckdb.ConsoleLogger();
const worker = await duckdb.createWorker(bundle.mainWorker);
const db = new duckdb.AsyncDuckDB(logger, worker);
await db.instantiate(bundle.mainModule);
return db;
}
db = makeDB()
query = `from read_parquet("https://idl.uw.edu/mosaic/data/flights-200k.parquet")`
connection = await db.connect()
connection.query(query)
connection.useUnsafe(async (bindings, conn) => {
const buffer = await bindings.runQuery(conn, query);
console.log("buffer", buffer);
const table = arrow.tableFromIPC(buffer);
console.log("table", table);
})
function getArrowIPC(conn, query) {
return new Promise((resolve, reject) => {
connection.useUnsafe(async (bindings, conn) => {
try {
const buffer = await bindings.runQuery(conn, query);
resolve(buffer);
} catch (error) {
reject(error);
}
});
});
}
buffer = getArrowIPC(connection, query)
table = arrow.tableFromIPC(buffer)
Purpose-built for displays of data
Observable is your go-to platform for exploring data and creating expressive data visualizations. Use reactive JavaScript notebooks for prototyping and a collaborative canvas for visual data exploration and dashboard creation.
