Statistics Pipeline Service
This repository contains code that processes NDT data and provides aggregate metrics by day for standard global, and some national geographies. The resulting aggregations are made available in JSON format, for use by other applications.
The stats-pipeline
service is written in Go, runs on GKE, and generates and
updates daily aggregate statistics. Access is provided in public BigQuery tables
and in per-year JSON formatted files hosted on GCS.
Documentation Provided for the Statistics Pipeline Service
- (This document) Overview of the
stats-pipeline
service, fields provided (schema), output formats, available geographies, and API URL structure. - What Statistics are Provided by stats-pipeline, and How are They Calculated?
- Geographic Precision in stats-pipeline
- Statistics Output Format, Schema, and Field Descriptions
- Statistics API URL Structure, Available Geographies & Aggregations
General Recommendations for All Aggregations of NDT data
In general, our recommendations for research aggregating NDT data are:
- Don't oversimplify
- Aggregate by ASN in addition to time/date and location
- Be aware of, and illustrate multimodal distributions
- Use histogram and logarithmic scales
- Take into account, and compensate for, client bias and population drift
Roadmap
Below we list additional features, methods, geographies, etc. which may be
considered for future versioned releases of stats-pipeline
.
Geographies
- US Zip Codes, US Congressional Districts, Block Groups, Blocks
Output Formats
- histogram_daily_stats.csv - Same data as the JSON, but in CSV. Useful for importing into a spreadsheet.
- histogram_daily_stats.sql - A SQL query which returns the same rows in the corresponding .json and .csv. Useful for verifying the exported data against the source and to tweak the query as needed by different use cases.