Statistician, interested in Data Science and R
Public
Edited
Oct 18, 2023
Paused
logs_stream = await FileAttachment("logs.ndjson").stream()
text_stream = logs_stream.pipeThrough(new TextDecoderStream())
reader = text_stream.getReader()
/*values = {
while (true) {
const { done, value } = await reader.read();
if (!done && value != null) {
mutable buffer = mutable buffer + value
} else {
await new Promise(resolve => setTimeout(resolve, 500));
}
let splits = buffer.split("\n");
while (splits.length > 1) {
//await new Promise(resolve => setTimeout(resolve, 500));
let json = splits.shift();
if (splits.length > 0) {
mutable buffer = splits.join("\n");
}
mutable data = [...data, JSON.parse(json)];
yield JSON.parse(json).log;
}
}
}*/
async function* parse_logs (reader) {
let buffer = ""
while (true) {
const { done, value } = await reader.read();
if (!done && value != null) {
buffer = buffer + value
} else {
await new Promise(resolve => setTimeout(resolve, 500));
}
let splits = buffer.split("\n");
while (splits.length > 1) {
//await new Promise(resolve => setTimeout(resolve, 500));
let json = splits.shift();
if (splits.length > 0) {
buffer = splits.join("\n");
}
yield JSON.parse(json);
}
}
}
mutable data = [];
json = parse_logs(reader)
table = htl.html`<table id="logs" style="white-space: break-spaces; font-family: monospace;"><tbody></tbody></table>`
{
table.querySelector("tbody").appendChild(htl.html`<tr><td>${json["log"]}</td></tr>`);
}
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.
