City Service Heat
Blend 311 requests, crime incidents, and closures into an anomaly lens with DP aware binning.
NYC 311 recent
- Street ConditionBRONXPothole2026-01-09T02:36:15.000
- Abandoned VehicleUnspecifiedWith License Plate2026-01-09T02:21:28.000
- Noise - ResidentialMANHATTANBanging/Pounding2026-01-09T02:20:09.000
- Non-Emergency Police MatterBRONXOther (complaint details)2026-01-09T02:19:28.000
- Noise - ResidentialBROOKLYNBanging/Pounding2026-01-09T02:19:23.000
- DrinkingBRONXIn Public2026-01-09T02:18:18.000
- Illegal ParkingSTATEN ISLANDPosted Parking Sign Violation2026-01-09T02:18:05.000
- Noise - ResidentialQUEENSBanging/Pounding2026-01-09T02:17:59.000
- Illegal ParkingQUEENSCommercial Overnight Parking2026-01-09T02:17:09.000
- Illegal ParkingQUEENSParking Permit Improper Use2026-01-09T02:15:57.000
- Noise - VehicleBROOKLYNEngine Idling2026-01-09T02:14:51.000
- Illegal ParkingBROOKLYNCommercial Overnight Parking2026-01-09T02:14:50.000
- Noise - ResidentialQUEENSBanging/Pounding2026-01-09T02:14:45.000
- Noise - CommercialMANHATTANLoud Music/Party2026-01-09T02:14:30.000
- Illegal ParkingQUEENSCommercial Overnight Parking2026-01-09T02:13:34.000
- Noise - Street/SidewalkBRONXLoud Music/Party2026-01-09T02:12:56.000
- Noise - ResidentialBROOKLYNBanging/Pounding2026-01-09T02:11:00.000
- Homeless Person AssistanceBRONXNon-Chronic2026-01-09T02:10:27.000
- Noise - ResidentialMANHATTANLoud Talking2026-01-09T02:09:35.000
- Noise - ResidentialBROOKLYNLoud Music/Party2026-01-09T02:09:18.000
- Noise - CommercialBROOKLYNBanging/Pounding2026-01-09T02:08:54.000
- Noise - VehicleBROOKLYNEngine Idling2026-01-09T02:08:53.000
- Dirty ConditionBRONXTrash2026-01-09T02:08:06.000
- Noise - ResidentialBROOKLYNLoud Music/Party2026-01-09T02:06:56.000
- Noise - CommercialMANHATTANLoud Music/Party2026-01-09T02:06:54.000
- Consumer ComplaintBROOKLYNStoop Line Stand2026-01-09T02:05:56.000
- Noise - ResidentialBROOKLYNLoud Music/Party2026-01-09T02:05:47.000
- Noise - ResidentialQUEENSBanging/Pounding2026-01-09T02:05:07.000
- Dirty ConditionBRONXTrash2026-01-09T02:05:00.000
- Blocked DrivewayQUEENSNo Access2026-01-09T02:04:05.000
- Illegal ParkingBROOKLYNBlocked Hydrant2026-01-09T02:03:34.000
- Illegal ParkingQUEENSBlocked Hydrant2026-01-09T02:03:04.000
- Noise - ResidentialBRONXBanging/Pounding2026-01-09T02:02:13.000
- Noise - ResidentialBROOKLYNLoud Music/Party2026-01-09T02:00:53.000
- Illegal ParkingQUEENSDouble Parked Blocking Traffic2026-01-09T02:00:45.000
- Noise - ResidentialBRONXBanging/Pounding2026-01-09T01:59:49.000
- Noise - ResidentialBROOKLYNLoud Music/Party2026-01-09T01:59:08.000
- Noise - ResidentialBROOKLYNLoud Music/Party2026-01-09T01:58:48.000
- Taxi ComplaintQUEENSDriver Complaint - Non Passenger2026-01-09T01:58:26.000
- Smoking or VapingMANHATTANAllowed in Smoke Free Area2026-01-09T01:58:24.000
- Homeless Person AssistanceMANHATTANNon-Chronic2026-01-09T01:58:06.000
- Street Sweeping ComplaintBROOKLYNStreet Not Swept2026-01-09T01:57:43.000
- Cannabis RetailerBRONXSales to Minors Under 212026-01-09T01:57:34.000
- Illegal ParkingBROOKLYNBlocked Hydrant2026-01-09T01:56:28.000
- Blocked DrivewayBRONXNo Access2026-01-09T01:56:23.000
- Noise - VehicleBRONXEngine Idling2026-01-09T01:55:57.000
- Noise - ResidentialQUEENSLoud Music/Party2026-01-09T01:55:45.000
- Noise - VehicleBRONXEngine Idling2026-01-09T01:54:11.000
- Noise - ResidentialSTATEN ISLANDBanging/Pounding2026-01-09T01:53:42.000
- Street Sign - DamagedMANHATTANOther/Unknown2026-01-09T01:53:41.000
Build goals
Blend 311 requests, crime incidents, and closures into an anomaly lens with DP aware binning.
Stack
- Frontend: React 18, Mapbox GL or deck.gl when needed, D3 for charts, TanStack Query, Zustand for local state, plain CSS with design tokens. No runtime CSS frameworks.
- API: Python 3.11 FastAPI or Node 20 Fastify (choose per project spec), Pydantic or Zod models, Uvicorn or Node cluster, OpenAPI JSON at /openapi.json.
- Storage: Redis 7 for hot cache, Postgres 15 with PostGIS for spatial and Timescale extension for time series where needed, S3 compatible bucket for tiles and artifacts.
- Ingest: Async fetchers with ETag or Last Modified, paging, retry with backoff and jitter, circuit breakers, structured logs.
- Tiles: Vector tiles for heavy map layers, long cache with ETag, CDN in front.
- Observability: Prometheus metrics, OpenTelemetry traces, structured logs, freshness and error rate alerts.
- Security: Keys server side only, CORS scoped, token bucket rate limits, audit logs for sensitive actions.
Data sources
| Source | Endpoint | Cadence | Access | Auth | Notes |
|---|---|---|---|---|---|
| NYC 311 | data.cityofnewyork.us/resource/erm2-nwe9.json | frequent | Socrata API | None | Service requests |
| Chicago 311 | data.cityofchicago.org/resource/v6vf-nfxy.json | frequent | Socrata API | None | Service requests |
| Chicago Crimes | data.cityofchicago.org/resource/ijzp-q8t2.json | frequent | Socrata API | None | Incidents |
| UK National Highways | developer.data.nationalhighways.co.uk | frequent | REST | Key | Closures and incidents |
Architecture
Python FastAPI, z score anomalies per tract, DP friendly binning, explainable drivers, PostGIS spatial joins, paging and caching.
Models
Models are expressed in DB tables and mirrored as API schemas. All timestamps are UTC. All coordinates are WGS84. Stable IDs, soft deletes by valid_to when needed.
- request(id, ts, category, geom, attrs jsonb)
- incident(id, ts, type, geom, severity)
- anomaly(tract_id, category, window, zscore, evidence jsonb)
Algorithms
- Rolling baselines per tract and category
- DP friendly binning, hide low counts
- Attribution by category mix contribution
API surface
- GET /heat?city=&bbox=&since=&until=&category=
- GET /anomalies?city=&since=&until=&min_z=
- GET /tracts?city=
UI and visualization
- Tilegrams that morph across admin levels
- Sparkbands per tile and brushed selection
- Narrative labels that explain drivers
Performance budgets
- City heat view p95 under 16 ms frame time
- API p95 under 300 ms for common filters
- FCP under 2 s on broadband mid tier laptop.
- API p95 under 300 ms for common list endpoints, p99 under 800 ms.
- Map render p95 frame time under 20 ms for target layers and volumes (document per tool).
- Frontend app code under 180 KB gzip excluding map library.
- API memory under 200 MB under normal load.
Accessibility
- WCAG 2.2 AA, automated axe checks clean, no critical issues.
- Keyboard navigable controls, focus rings visible, ARIA roles correct.
- Color contrast at or above 4.5 to 1, colorblind safe palettes.
- Live regions announce dynamic updates, prefers reduced motion honored.
Evidence pack and quality gates
- Contract tests with recorded cassettes for each provider, JSON Schema validation, drift alarms within 15 minutes.
- Load tests with k6, thresholds enforced in CI for p95 and p99.
- Lighthouse performance and a11y reports stored as CI artifacts.
- Golden tests for algorithms with synthetic datasets and expected outputs.
- Cost workbook with cache hit ratios, tile and API egress estimates, retention policies.
CI configuration
name: ci
on: [push, pull_request]
jobs:
api:
runs-on: ubuntu-latest
services:
postgres:
image: postgis/postgis:15-3.3
ports: [ "5432:5432" ]
env: { POSTGRES_PASSWORD: postgres }
redis:
image: redis:7
ports: [ "6379:6379" ]
steps:
- uses: actions/checkout@v4
- uses: actions/setup-node@v4
with: { node-version: "20" }
- uses: actions/setup-python@v5
with: { python-version: "3.11" }
- run: pip install -e packages/api[dev] || true
- run: psql postgresql://postgres:postgres@localhost:5432/postgres -f packages/api/src/db/schema.sql || true
- run: pytest -q packages/api/src/tests || true
- run: cd packages/web && npm ci && npm run build && npm test --silentRisks and mitigations
- Schema drift across cities, isolate in adapters with tests
- Privacy risks, enforce suppression and aggregation thresholds
Acceptance checklist
- CI green on main, all quality gates met.
- Freshness SLOs met for hot regions or feeds.
- Performance budgets met or better.
- A11y audits pass with zero critical findings.
- Provenance and license panels render correct metadata.
- Runbook covers stale feed handling, provider errors, and key rotation.
Implementation sequence
- Adapters with paging and where clauses
- Anomaly engine and DP binning
- Tilegrams, sparkbands, and narratives
- Evidence pack and privacy checks
Runbook
make up # docker compose up db, redis, api, web
make ingest # start ingest workers for this tool
make tiles # build vector tiles if applicable
make test # unit + contract + golden
make e2e # browser tests