Skip to content

Commit

Permalink
InfluxDB Uploading Test Scripts
Browse files Browse the repository at this point in the history
  • Loading branch information
@ethanclewis
ethanclewis committed Oct 24, 2024
1 parent 13e245a commit d41881e
Show file tree
Hide file tree
Showing 3 changed files with 82 additions and 18 deletions.
Binary file modified .DS_Store
View file
Binary file not shown.
64 changes: 64 additions & 0 deletions InfluxDB Testing/InfluxDB_TEST.py
View file
Original file line number Diff line number Diff line change
@@ -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)
36 changes: 18 additions & 18 deletions InfluxDB Testing/InfluxDB_Test.ipynb
View file
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
"cells": [
{
"cell_type": "code",
"execution_count": 17,
"execution_count": 16,
"metadata": {},
"outputs": [],
"source": [
Expand All @@ -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",
Expand All @@ -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",
Expand All @@ -73,7 +73,7 @@
},
{
"cell_type": "code",
"execution_count": 20,
"execution_count": 19,
"metadata": {},
"outputs": [],
"source": [
Expand All @@ -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",
Expand All @@ -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"
]
},
Expand All @@ -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"
]
}
],
Expand All @@ -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"
]
}
],
Expand Down

0 comments on commit d41881e

Please sign in to comment.