EJ Fox & Ian Johnson
streaming data, code, acid, design
filtered.map(d => d.v)
legend({ color: colorScale.domain(cutoffExtent) })
import { legend } from "@d3/color-legend"
weeks = d3.range(example.length).reverse()
function value(d) {
if (!d) return 1;
let used = +d["icu_beds_used_7_day_avg"];
let total = +d["total_icu_beds_7_day_avg"];
// there is an assumption
// if (total < used) total = used;
// percent icu used out of total on average
return used / total;
}
example = eventsByHospital.get("310024")
filtered = hospitals
.filter(d => {
let events = eventsByHospital.get(d.hospital_pk);
if (events && events[week]) return value(events[week]) > cutoffPercent;
})
.sort(function(a, b) {
let eventsA = eventsByHospital.get(a.hospital_pk);
let eventsB = eventsByHospital.get(b.hospital_pk);
if (!eventsA || !eventsB) return -1;
return value(eventsA[week]) - value(eventsB[week]);
})
.map(d => {
let p = projection([d.LONGITUDE, d.LATITUDE]);
// total_icu_beds_7_day_avg
// icu_beds_used_7_day_avg
// total_beds_7_day_avg
let events = eventsByHospital.get(d.hospital_pk);
// console.log(d, events);
// if (!events || !events.length) return;
if (events && events[week] && p) {
let v = value(events[week]);
return {
...d,
events: events,
v
};
}
return null;
// return eventsByHospital.get(d.hospital_pk)[week]; //.map(d => value(d));
})
.filter(d => !!d)
metrics = [
"total_icu_beds_7_day_avg",
"total_staffed_adult_icu_beds_7_day_avg",
"icu_beds_used_7_day_avg"
]
metric = metrics[0]
// colorScale = d3.scaleSequential(d3.interpolateGreys)
// colorScale = d3.scaleSequential(d3.interpolateMagma)
colorScale = d3.scaleSequential(d3.interpolateTurbo)
extent = d3.extent(eventsByHospital, d => value(d[1][week])) //[cutoffPercent, 101]
cutoffExtent = [cutoffPercent, 1]
metricNormalize = d3
.scaleLinear()
.range([0, 1])
// .domain(extent)
.domain([cutoffPercent, 1])
metricRadius = d3
.scaleSqrt()
.range([1, 3])
// .domain(extent)
.domain([cutoffPercent, 1])
eventsByHospital.get("010108")
import { countyShapes, stateShapes } from "@enjalot/us-county-datasets"
import { scaleCanvas } from "@john-guerra/canvas-retina-display"
mapWidth = hires == "true" ? 4096 : width
height = hires == "true" ? 2048 : width * 0.67
hospitals = FileAttachment("hospitals-maplarge.csv").csv()
hospitalsByPK = new Map(hospitals.map(d => [d.hospital_pk, d]))
hhs = FileAttachment(
"slimmed-reported_hospital_capacity_admissions_facility-level_weekly_average_timeseries_20201207.csv"
).csv()
hhs.filter(d => d.hospital_pk == "010108")
// how many events per hospital (seems 18)
d3.rollup(hhs, v => v.length, d => d.hospital_pk)
eventsByHospital = d3.group(hhs, d => d.hospital_pk)
// how many events per county
d3.rollup(hhs, v => v.length, d => hospitalsByPK.get(d.hospital_pk).fips_code)
d3 = require("d3@6", "d3-geo", "d3-geo-projection@3")
/*
mkdir data
curl https://healthdata.gov/sites/default/files/reported_hospital_capacity_admissions_facility-level_weekly_average_timeseries_20201207.csv > data/reported_hospital_capacity_admissions_facility-level_weekly_average_timeseries_20201207.csv
npm install d3
node slim.js
*/
/*
let fs = require("fs")
let d3 = require("d3")
let dir = "data/"
let filename = "reported_hospital_capacity_admissions_facility-level_weekly_average_timeseries_20201207.csv"
let txt = fs.readFileSync(dir + filename).toString().slice(1) // weird character at begin of file
let data = d3.csvParse(txt)
let todelete = "hospital_name,address,city,state,zip,fips_code,hospital_subtype,ccn,is_metro_micro".split(",")
Object.keys(data[0]).forEach(key => {
if(key.indexOf("previous_day") >= 0) {
todelete += "," + key
}
})
todelete = todelete.split(",")
console.log("todelete", todelete)
let slimmed = data
.filter(d => !!d.address)
// .filter(d => !!d.fips_code)
.map(function(d) {
let obj = {...d}
Object.keys(obj).forEach(key => {
let v = obj[key]
if(v == "-999999" || v == "-999999.0") obj[key] = ""
})
// we can look up all these fields in the hospitals geocoded map
todelete.forEach(del => {
delete obj[del]
})
return obj
})
console.log("writing slimmed full file")
fs.writeFileSync(dir + "slimmed-" + filename, d3.csvFormat(slimmed))
// // let byStateFips = d3.rollup(data, v => v.length, d => d.fips_code.slice(0,2))
let byStateFips = d3.group(data, d => d.fips_code.slice(0,2))
let states = Array.from(byStateFips.keys())
states.forEach(state => {
let d = byStateFips.get(state)
console.log(state, d.length)
fs.writeFileSync(dir + state + "-slimmed-" + filename, d3.csvFormat(d))
})
*/
import { world } from "@d3/world-map"
topojson = require("topojson-client@3")
import { select } from "@jashkenas/inputs"
import { Scrubber } from "@mbostock/scrubber"
land = topojson.feature(world, world.objects.land)
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.
