Your Data, Your Privacy: Building a Collaborative Allergy Predictor with Federated Learning

We live in an era where our smartphones know more about our health than we do. From heart rate variability to sleep patterns, personal devices are goldmines for predictive health models. However, the "Health Data Paradox" remains: we want smarter AI to predict things like allergy triggers, but we don't want to upload our intimate medical logs to a centralized cloud.

This is where Federated Learning and Privacy-Preserving AI come to the rescue. By leveraging Decentralized Machine Learning techniques, we can train powerful global models while keeping raw data strictly on-device. In this guide, we’ll explore how to build a collaborative allergy prediction system using the Flower (flwr) framework and PyTorch, ensuring that your pixels and vitals never leave your pocket.

Unlike traditional machine learning where data is moved to the model, in Federated Learning, the model is moved to the data.

sequenceDiagram
    participant S as Central Aggregator (Server)
    participant C1 as Smartphone A (Edge)
    participant C2 as Smartphone B (Edge)

    Note over S: Initialize Global Model
    S->>C1: Send Global Weights
    S->>C2: Send Global Weights

    Note over C1: Train on Local Health Data
    Note over C2: Train on Local Health Data

    C1->>S: Send Local Gradients/Updates
    C2->>S: Send Local Gradients/Updates

    Note over S: Aggregate Updates (FedAvg)
    Note over S: Update Global Model
    S->>C1: Send Improved Model
    S->>C2: Send Improved Model

In this flow, the Central Aggregator

never sees the raw allergy logs. It only receives mathematical weight updates (gradients), which are then averaged to improve the master model.

To follow this advanced tutorial, you should have a basic grasp of neural network training. Our tech stack includes:

First, we define a simple Multi-Layer Perceptron (MLP). This model will take inputs like pollen count, humidity, and recent diet to predict the likelihood of an allergic reaction.

import torch
import torch.nn as nn
import torch.nn.functional as F

class AllergyNet(nn.Module):
    def __init__(self):
        super(AllergyNet, self).__init__()
        self.fc1 = nn.Linear(10, 32) # 10 health features
        self.fc2 = nn.Linear(32, 16)
        self.fc3 = nn.Linear(16, 1) # Binary output: Reaction or No Reaction

    def forward(self, x):
        x = F.relu(self.fc1(x))
        x = F.relu(self.fc2(x))
        return torch.sigmoid(self.fc3(x))

def train(net, train, epochs):
    criterion = nn.BCELoss()
    optimizer = torch.optim.SGD(net.parameters(), lr=0.01)
    for _ in range(epochs):
        for images, labels in train:
            optimizer.zero_grad()
            criterion(net(images), labels).backward()
            optimizer.step()

The "Client" represents the code running on the user's smartphone. It wraps our PyTorch model and tells the Flower server how to fetch parameters and train locally.

import flwr as fl
from collections import OrderedDict

class AllergyClient(fl.client.NumPyClient):
    def __init__(self, model, train):
        self.model = model
        self.train = train

    def get_parameters(self, config):
        return [val.cpu().numpy() for _, val in self.model.state_dict().items()]

    def set_parameters(self, parameters):
        params_dict = zip(self.model.state_dict().keys(), parameters)
        state_dict = OrderedDict({k: torch.tensor(v) for k, v in params_dict})
        self.model.load_state_dict(state_dict, strict=True)

    def fit(self, parameters, config):
        self.set_parameters(parameters)
        train(self.model, self.train, epochs=1)
        return self.get_parameters(config={}), len(self.train.dataset), {}

    def evaluate(self, parameters, config):
        self.set_parameters(parameters)
        return 0.5, len(self.train.dataset), {"accuracy": 0.9}

The server is responsible for coordinating the rounds of training. It waits for clients to connect, sends the initial weights, and aggregates the results using an algorithm like FedAvg.

import flwr as fl

if __name__ == "__main__":
    strategy = fl.server.strategy.FedAvg(
        fraction_fit=1.0,  # Sample 100% of available clients
        min_fit_clients=2, # Wait for at least 2 clients
    )

    fl.server.start_server(
        server_address="0.0.0.0:8080",
        config=fl.server.ServerConfig(num_rounds=3),
        strategy=strategy,
    )

While the example above works for a proof-of-concept, production-grade health apps require robust security measures like Differential Privacy (DP) and Secure Multi-Party Computation (SMPC).

For deeper insights into deploying privacy-preserving models at scale and optimizing Edge AI performance, I highly recommend checking out the ** WellAlly Tech Blog**. They provide excellent deep dives into production-ready architectures, including how to handle non-IID (Independent and Identically Distributed) data in medical settings—a common hurdle where different users have vastly different allergy triggers.

To simulate real-world deployment, we use Docker. This ensures our client code is portable and isolated.

FROM python:3.9-slim

WORKDIR /app
COPY requirements.txt .
RUN pip install -r requirements.txt

COPY client.py model.py .

CMD ["python", "client.py", "--server_address", "server:8080"]

By moving the computation to the edge, we’ve built a system that learns from collective experience without ever compromising individual privacy. Federated Learning isn't just a buzzword; it's a fundamental shift in how we handle sensitive health data.

Next steps for your project:

Opacus

with PyTorch to add noise to gradients.Are you ready to build AI that respects user boundaries? Let me know in the comments how you're using Edge AI! 👇