diff --git a/prisma/migrations/20241217025513_add_wind_columns_to_environment_metrics_table/migration.sql b/prisma/migrations/20241217025513_add_wind_columns_to_environment_metrics_table/migration.sql
new file mode 100644
index 0000000..04070de
--- /dev/null
+++ b/prisma/migrations/20241217025513_add_wind_columns_to_environment_metrics_table/migration.sql
@@ -0,0 +1,5 @@
+-- AlterTable
+ALTER TABLE `environment_metrics` ADD COLUMN `wind_direction` INTEGER NULL,
+    ADD COLUMN `wind_gust` DECIMAL(65, 30) NULL,
+    ADD COLUMN `wind_lull` DECIMAL(65, 30) NULL,
+    ADD COLUMN `wind_speed` DECIMAL(65, 30) NULL;
diff --git a/prisma/schema.prisma b/prisma/schema.prisma
index 41c36df..6741657 100644
--- a/prisma/schema.prisma
+++ b/prisma/schema.prisma
@@ -133,6 +133,10 @@ model EnvironmentMetric {
   voltage             Decimal?
   current             Decimal?
   iaq                 Int?
+  wind_direction      Int?
+  wind_speed          Decimal?
+  wind_gust           Decimal?
+  wind_lull           Decimal?
 
   created_at DateTime @default(now())
   updated_at DateTime @default(now()) @updatedAt
diff --git a/src/mqtt.js b/src/mqtt.js
index 27df269..f960619 100644
--- a/src/mqtt.js
+++ b/src/mqtt.js
@@ -1118,6 +1118,10 @@ client.on("message", async (topic, message) => {
                 const voltage = telemetry.environmentMetrics.voltage !== 0 ? telemetry.environmentMetrics.voltage : null;
                 const current = telemetry.environmentMetrics.current !== 0 ? telemetry.environmentMetrics.current : null;
                 const iaq = telemetry.environmentMetrics.iaq !== 0 ? telemetry.environmentMetrics.iaq : null;
+                const windDirection = telemetry.environmentMetrics.windDirection;
+                const windSpeed = telemetry.environmentMetrics.windSpeed;
+                const windGust = telemetry.environmentMetrics.windGust;
+                const windLull = telemetry.environmentMetrics.windLull;
 
                 // set metrics to update on node table
                 data.temperature = temperature;
@@ -1151,6 +1155,10 @@ client.on("message", async (topic, message) => {
                                 voltage: voltage,
                                 current: current,
                                 iaq: iaq,
+                                wind_direction: windDirection,
+                                wind_speed: windSpeed,
+                                wind_gust: windGust,
+                                wind_lull: windLull,
                             },
                         });
                     }