import pandas as pd
import numpy as np
from sklearn.preprocessing import StandardScaler
import torch
import torch.nn as nn
import torch.optim as optim
from torch.utils.data import DataLoader, TensorDataset
# Load the Air Quality dataset from the URL
url = "https://codesignal-staging-assets.s3.amazonaws.com/uploads/1742293523899/AirQualityUCI.csv"
df = pd.read_csv(url, sep=';', decimal=',')
# Replace -200 with NaN
df.replace(-200, np.nan, inplace=True)
# Combine 'Date' and 'Time' into a single 'DateTime' column
df['DateTime'] = pd.to_datetime(df['Date'] + ' ' + df['Time'], format="%d/%m/%Y %H.%M.%S")
# Drop the original 'Date' and 'Time' columns
df.drop(columns=['Date', 'Time'], inplace=True)
# Drop unnecessary columns
df.drop(columns=['Unnamed: 15', 'Unnamed: 16'], inplace=True)
# Drop rows where essential features are missing
df.dropna(subset=['CO(GT)', 'NO2(GT)', 'T', 'RH'], inplace=True)
# Fill missing values using forward-fill & backward-fill
df.ffill(inplace=True)
df.bfill(inplace=True)
# Set DateTime as index
df.set_index('DateTime', inplace=True)
# Select relevant features for RNN
features = ['CO(GT)', 'NO2(GT)', 'PT08.S5(O3)', 'RH', 'T']
df_selected = df[features]
# Normalize the data
scaler = StandardScaler()
df_scaled = scaler.fit_transform(df_selected)
# Function to create sequences for multi-input RNN
def create_multivariate_sequences(data, seq_length=10):
X, y = [], []
for i in range(len(data) - seq_length):
X.append(data[i:i+seq_length]) # Multi-feature input
y.append(data[i+seq_length, -1]) # Predicting Temperature (T)
return np.array(X), np.array(y)
# Define sequence length
sequence_length = 10
# Create sequences
X, y = create_multivariate_sequences(df_scaled, sequence_length)
# Define train/test split ratio
train_ratio = 0.8
train_size = int(len(X) * train_ratio)
# Split the data
X_train, X_test = X[:train_size], X[train_size:]
y_train, y_test = y[:train_size], y[train_size:]
# Convert to PyTorch tensors
X_train_tensor = torch.tensor(X_train, dtype=torch.float32)
y_train_tensor = torch.tensor(y_train, dtype=torch.float32)
X_test_tensor = torch.tensor(X_test, dtype=torch.float32)
y_test_tensor = torch.tensor(y_test, dtype=torch.float32)
# Create DataLoader for training
train_dataset = TensorDataset(X_train_tensor, y_train_tensor)
train_dataloader = DataLoader(train_dataset, batch_size=16, shuffle=True)
# Define a modified RNN model for multivariate time series
class RNNModel(nn.Module):
def __init__(self, input_size, hidden_size, output_size):
super(RNNModel, self).__init__()
self.rnn = nn.RNN(input_size, hidden_size, batch_first=True)
self.fc1 = nn.Linear(hidden_size, 10)
self.fc2 = nn.Linear(10, output_size)
def forward(self, x):
out, _ = self.rnn(x)
out = torch.relu(self.fc1(out[:, -1, :]))
out = self.fc2(out)
return out
# Initialize model, loss function, and optimizer
model = RNNModel(input_size=len(features), hidden_size=30, output_size=1)
criterion = nn.MSELoss()
optimizer = optim.Adam(model.parameters(), lr=0.001)
# Train model
for epoch in range(5):
for batch_X, batch_y in train_dataloader:
optimizer.zero_grad()
outputs = model(batch_X)
loss = criterion(outputs, batch_y.unsqueeze(1))
loss.backward()
optimizer.step()
print(f'Epoch [{epoch+1}/5], Loss: {loss.item():.4f}')