diff --git a/.DS_Store b/.DS_Store index 5041aa3..53db974 100644 Binary files a/.DS_Store and b/.DS_Store differ diff --git a/InfluxDB Testing/InfluxDB_TEST.py b/InfluxDB Testing/InfluxDB_TEST.py new file mode 100644 index 0000000..6612008 --- /dev/null +++ b/InfluxDB Testing/InfluxDB_TEST.py @@ -0,0 +1,64 @@ +import time +from influxdb_client import InfluxDBClient, Point +from influxdb_client.client.write_api import SYNCHRONOUS +import certifi +import pandas as pd + + +# InfluxDB configuration +token = '8Kph_oFbnNqTvgUfERhTJveJpw1A08-HDsnhftEIYj8HRSUJSmKIdoPZdaIbNeIkG4likhDrOtr5FgyF5W03hg==' +org = "Ethan" +bucket = "Test" # Use "bucket" instead of "database" in influxdb-client +url = "https://us-east-1-1.aws.cloud2.influxdata.com" + +# Create InfluxDB client +client = InfluxDBClient(url=url, token=token, org=org, ssl_ca_cert=certifi.where()) +write_api = client.write_api(write_options=SYNCHRONOUS) + + +# Example sensor data (hardcoded) +dht_sensor_data = [ + {"Zone": "Zone 1", "Temp_C": 20.5, "Temp_F": 68.9, "Humidity": 55.0}, + {"Zone": "Zone 2", "Temp_C": 21.0, "Temp_F": 69.8, "Humidity": 60.0}, + {"Zone": "Zone 3", "Temp_C": 19.8, "Temp_F": 67.6, "Humidity": 58.0}, +] + +water_sensor_data = [ + {"sensor": "water_sensor", "RTD": 0.98, "pH": 6.5, "EC": 1.1}, + {"sensor": "water_sensor", "RTD": 0.95, "pH": 6.6, "EC": 1.2}, + {"sensor": "water_sensor", "RTD": 0.99, "pH": 6.4, "EC": 1.3}, +] + + +# Function to upload DHT sensor data to InfluxDB +def upload_dht_data(data): + for entry in data: + point = ( + Point("dht_sensors") # Measurement for DHT sensors + .tag("Zone", entry["Zone"]) # Tag for sensor type + .field("Temp_C", entry["Temp_C"]) # Temperature in Celsius + .field("Temp_F", entry["Temp_F"]) # Temperature in Fahrenheit + .field("Humidity", entry["Humidity"]) # Humidity level + ) + write_api.write(bucket=bucket, org=org, record=point) + print(f"Uploaded DHT sensor data from {entry['Zone']}: {entry}") + time.sleep(1) # Optional: Delay to simulate real-time data collection + +# Function to upload water sensor data to InfluxDB +def upload_water_data(data): + for entry in data: + point = ( + Point("water_sensors") # Measurement for water sensors + .field("RTD", entry["RTD"]) # RTD value + .field("pH", entry["pH"]) # pH value + .field("EC", entry["EC"]) # Electrical conductivity + ) + write_api.write(bucket=bucket, org=org, record=point) + print(f"Uploaded water sensor data: {entry}") + time.sleep(1) # Optional: Delay to simulate real-time data collection + + +# Upload data for DHT sensors +upload_dht_data(dht_sensor_data) +# Upload data for water sensors +upload_water_data(water_sensor_data) \ No newline at end of file diff --git a/InfluxDB Testing/InfluxDB_Test.ipynb b/InfluxDB Testing/InfluxDB_Test.ipynb index 2b24569..aa93e4e 100644 --- a/InfluxDB Testing/InfluxDB_Test.ipynb +++ b/InfluxDB Testing/InfluxDB_Test.ipynb @@ -2,7 +2,7 @@ "cells": [ { "cell_type": "code", - "execution_count": 17, + "execution_count": 16, "metadata": {}, "outputs": [], "source": [ @@ -22,14 +22,14 @@ }, { "cell_type": "code", - "execution_count": 18, + "execution_count": 17, "metadata": {}, "outputs": [], "source": [ "# InfluxDB configuration\n", "token = '8Kph_oFbnNqTvgUfERhTJveJpw1A08-HDsnhftEIYj8HRSUJSmKIdoPZdaIbNeIkG4likhDrOtr5FgyF5W03hg=='\n", "org = \"Ethan\"\n", - "bucket = \"DashboardTest\" # Use \"bucket\" instead of \"database\" in influxdb-client\n", + "bucket = \"Test\" # Use \"bucket\" instead of \"database\" in influxdb-client\n", "url = \"https://us-east-1-1.aws.cloud2.influxdata.com\"\n", "\n", "# Create InfluxDB client\n", @@ -46,15 +46,15 @@ }, { "cell_type": "code", - "execution_count": 19, + "execution_count": 18, "metadata": {}, "outputs": [], "source": [ "# Example sensor data (hardcoded)\n", "dht_sensor_data = [\n", - " {\"Zone\": \"DHT17\", \"Temp_C\": 20.5, \"Temp_F\": 68.9, \"Humidity\": 55},\n", - " {\"Zone\": \"DHT18\", \"Temp_C\": 21.0, \"Temp_F\": 69.8, \"Humidity\": 60},\n", - " {\"Zone\": \"DHT22\", \"Temp_C\": 19.8, \"Temp_F\": 67.6, \"Humidity\": 58},\n", + " {\"Zone\": \"Zone 1\", \"Temp_C\": 20.5, \"Temp_F\": 68.9, \"Humidity\": 55.0},\n", + " {\"Zone\": \"Zone 2\", \"Temp_C\": 21.0, \"Temp_F\": 69.8, \"Humidity\": 60.0},\n", + " {\"Zone\": \"Zone 3\", \"Temp_C\": 19.8, \"Temp_F\": 67.6, \"Humidity\": 58.0},\n", "]\n", "\n", "water_sensor_data = [\n", @@ -73,7 +73,7 @@ }, { "cell_type": "code", - "execution_count": 20, + "execution_count": 19, "metadata": {}, "outputs": [], "source": [ @@ -88,7 +88,7 @@ " .field(\"Humidity\", entry[\"Humidity\"]) # Humidity level\n", " )\n", " write_api.write(bucket=bucket, org=org, record=point)\n", - " print(f\"Uploaded DHT sensor data from {entry['sensor']}: {entry}\")\n", + " print(f\"Uploaded DHT sensor data from {entry['Zone']}: {entry}\")\n", " time.sleep(1) # Optional: Delay to simulate real-time data collection\n", "\n", "# Function to upload water sensor data to InfluxDB\n", @@ -101,7 +101,7 @@ " .field(\"EC\", entry[\"EC\"]) # Electrical conductivity\n", " )\n", " write_api.write(bucket=bucket, org=org, record=point)\n", - " print(f\"Uploaded water sensor data from {entry['sensor']}: {entry}\")\n", + " print(f\"Uploaded water sensor data: {entry}\")\n", " time.sleep(1) # Optional: Delay to simulate real-time data collection" ] }, @@ -114,16 +114,16 @@ }, { "cell_type": "code", - "execution_count": 21, + "execution_count": 20, "metadata": {}, "outputs": [ { "name": "stdout", "output_type": "stream", "text": [ - "Uploaded DHT sensor data from DHT17: {'sensor': 'DHT17', 'Temp_C': 20.5, 'Temp_F': 68.9, 'Humidity': 55}\n", - "Uploaded DHT sensor data from DHT18: {'sensor': 'DHT18', 'Temp_C': 21.0, 'Temp_F': 69.8, 'Humidity': 60}\n", - "Uploaded DHT sensor data from DHT22: {'sensor': 'DHT22', 'Temp_C': 19.8, 'Temp_F': 67.6, 'Humidity': 58}\n" + "Uploaded DHT sensor data from Zone 1: {'Zone': 'Zone 1', 'Temp_C': 20.5, 'Temp_F': 68.9, 'Humidity': 55.0}\n", + "Uploaded DHT sensor data from Zone 2: {'Zone': 'Zone 2', 'Temp_C': 21.0, 'Temp_F': 69.8, 'Humidity': 60.0}\n", + "Uploaded DHT sensor data from Zone 3: {'Zone': 'Zone 3', 'Temp_C': 19.8, 'Temp_F': 67.6, 'Humidity': 58.0}\n" ] } ], @@ -134,16 +134,16 @@ }, { "cell_type": "code", - "execution_count": 22, + "execution_count": 21, "metadata": {}, "outputs": [ { "name": "stdout", "output_type": "stream", "text": [ - "Uploaded water sensor data from water_sensor: {'sensor': 'water_sensor', 'RTD': 0.98, 'pH': 6.5, 'EC': 1.1}\n", - "Uploaded water sensor data from water_sensor: {'sensor': 'water_sensor', 'RTD': 0.95, 'pH': 6.6, 'EC': 1.2}\n", - "Uploaded water sensor data from water_sensor: {'sensor': 'water_sensor', 'RTD': 0.99, 'pH': 6.4, 'EC': 1.3}\n" + "Uploaded water sensor data: {'sensor': 'water_sensor', 'RTD': 0.98, 'pH': 6.5, 'EC': 1.1}\n", + "Uploaded water sensor data: {'sensor': 'water_sensor', 'RTD': 0.95, 'pH': 6.6, 'EC': 1.2}\n", + "Uploaded water sensor data: {'sensor': 'water_sensor', 'RTD': 0.99, 'pH': 6.4, 'EC': 1.3}\n" ] } ],