Why Every Data Scientist Should Learn Node.js in 2026

# pip install fastapi uvicorn   Run: uvicorn model_api:app --port 8000
from fastapi import FastAPI
from pydantic import BaseModel, Field

app = FastAPI()

class Customer(BaseModel):
    tenure_months: float = Field(ge=0)
    monthly_spend: float = Field(ge=0)

@app.post("/predict")
def predict(c: Customer):
    # stand-in for a trained model
    risk = 0.8 if c.tenure_months < 3 else 0.2
    return {"churn_risk": risk, "model_version": "1.0.0"}

// Node 18+ (built-in fetch). Run: node client.js
async function getChurnRisk(customer) {
  const controller = new AbortController();
  const timer = setTimeout(() => controller.abort(), 2000);   // 2s timeout
  try {
    const res = await fetch('http://localhost:8000/predict', {
      method: 'POST',
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify(customer),
      signal: controller.signal,
    });
    if (!res.ok) throw new Error(`model API returned ${res.status}`);
    return await res.json();
  } catch (err) {
    console.error('fallback used:', err.message);
    return { churn_risk: null, model_version: 'unavailable' };   // safe fallback
  } finally {
    clearTimeout(timer);
  }
}

getChurnRisk({ tenure_months: 2, monthly_spend: 499 }).then(console.log);

// npm install express   Run: node demo-server.js
const express = require('express');
const app = express();
app.use(express.urlencoded({ extended: false }));

app.get('/', (req, res) => res.send(`
  <form method="post">
    <label>Tenure (months) <input name="tenure_months" type="number" min="0" required></label>
    <label>Monthly spend <input name="monthly_spend" type="number" min="0" required></label>
    <button>Predict</button>
  </form>`));

app.post('/', async (req, res) => {
  const body = { tenure_months: Number(req.body.tenure_months), monthly_spend: Number(req.body.monthly_spend) };
  const r = await fetch('http://localhost:8000/predict', {
    method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(body) });
  const out = await r.json();
  res.send(`<p>Churn risk: ${out.churn_risk}</p><a href="/">Try again</a>`);
});

app.listen(3000, () => console.log('demo on http://localhost:3000'));

const express = require('express');
const fs = require('fs');
const app = express();
app.use(express.json());

// Collect 'this prediction was wrong' feedback for later analysis
app.post('/feedback', (req, res) => {
  const { prediction_id, correct } = req.body;
  if (typeof prediction_id !== 'string' || typeof correct !== 'boolean') {
    return res.status(400).json({ error: 'prediction_id and correct are required' });
  }
  fs.appendFileSync('feedback.jsonl', JSON.stringify({ prediction_id, correct, ts: Date.now() }) + '\n');
  res.status(201).json({ saved: true });
});

app.listen(3001);

// npm install express   Run: node events.js
const express = require('express');
const fs = require('fs');
const app = express();
app.use(express.json());

app.post('/events', (req, res) => {
  const { user_id, event, ts } = req.body;
  if (!user_id || !event) return res.status(400).json({ error: 'user_id and event required' });
  const record = { user_id, event, ts: ts || new Date().toISOString() };
  fs.appendFileSync('events.jsonl', JSON.stringify(record) + '\n');   // one JSON per line
  res.status(202).json({ accepted: true });
});

app.listen(3002, () => console.log('event collector on 3002'));

import json
import pandas as pd

# Read the JSON Lines file written by the Node.js collector
with open("events.jsonl") as f:
    events = [json.loads(line) for line in f if line.strip()]

df = pd.DataFrame(events)
df["ts"] = pd.to_datetime(df["ts"], errors="coerce")
print(df.groupby("event").size().sort_values(ascending=False))
# JSON Lines is a simple, shared format between Node.js and Python.

Days 1-2   JavaScript basics: variables, functions, objects, arrays
Days 3-4   async/await and fetch
Days 5-6   Node.js and npm; run scripts
Days 7-8   Express: routes, JSON requests and responses
Days 9-10  Call a Python FastAPI model from Node.js
Days 11-12 Error handling, timeouts and fallbacks
Days 13-14 Build a prediction demo and document the API contract

Endpoint: POST /predict
Request JSON:
  tenure_months: number >= 0
  monthly_spend: number >= 0
Response JSON:
  churn_risk: number 0-1
  model_version: string
Errors:
  422 if inputs invalid
Timeout: client waits up to 2 seconds, then uses fallback
Owner: data science team

Project: Churn model in a web demo

- Python FastAPI model service with input validation
- Node.js Express app with a form and result page
- Timeout and fallback handling
- Feedback endpoint writing JSON Lines
- Python notebook analysing feedback
- README with the API contract and a diagram