Commit d96de12f authored by Gezer's avatar Gezer
Browse files

Added a working query to the backend application

parent d00e180d
Showing with 23 additions and 6 deletions
+23 -6
...@@ -11,4 +11,8 @@ client = InfluxDBHelper( ...@@ -11,4 +11,8 @@ client = InfluxDBHelper(
bucket=os.getenv("INFLUXDB_BUCKET"), bucket=os.getenv("INFLUXDB_BUCKET"),
) )
client.get_all_data tables = client.get_all_data()
for table in tables:
for record in table.records:
print(record)
\ No newline at end of file
...@@ -18,7 +18,8 @@ requires-python = ">=3.12" ...@@ -18,7 +18,8 @@ requires-python = ">=3.12"
dependencies = [ dependencies = [
"django>=5.2", "django>=5.2",
"django-cors-headers>=4.7.0", "django-cors-headers>=4.7.0",
"influxdb-client>=1.40" "influxdb-client>=1.40",
"python-dotenv",
] ]
[dependency-groups] [dependency-groups]
......
...@@ -19,9 +19,10 @@ dependencies = [ ...@@ -19,9 +19,10 @@ dependencies = [
{ name = "django" }, { name = "django" },
{ name = "django-cors-headers" }, { name = "django-cors-headers" },
{ name = "influxdb-client" }, { name = "influxdb-client" },
{ name = "python-dotenv" },
] ]
[package.optional-dependencies] [package.dev-dependencies]
dev = [ dev = [
{ name = "ruff" }, { name = "ruff" },
] ]
...@@ -31,9 +32,11 @@ requires-dist = [ ...@@ -31,9 +32,11 @@ requires-dist = [
{ name = "django", specifier = ">=5.2" }, { name = "django", specifier = ">=5.2" },
{ name = "django-cors-headers", specifier = ">=4.7.0" }, { name = "django-cors-headers", specifier = ">=4.7.0" },
{ name = "influxdb-client", specifier = ">=1.40" }, { name = "influxdb-client", specifier = ">=1.40" },
{ name = "ruff", marker = "extra == 'dev'", specifier = ">=0.11.5" }, { name = "python-dotenv" },
] ]
provides-extras = ["dev"]
[package.metadata.requires-dev]
dev = [{ name = "ruff", specifier = ">=0.11.5" }]
[[package]] [[package]]
name = "certifi" name = "certifi"
...@@ -99,6 +102,15 @@ wheels = [ ...@@ -99,6 +102,15 @@ wheels = [
{ url = "https://files.pythonhosted.org/packages/ec/57/56b9bcc3c9c6a792fcbaf139543cee77261f3651ca9da0c93f5c1221264b/python_dateutil-2.9.0.post0-py2.py3-none-any.whl", hash = "sha256:a8b2bc7bffae282281c8140a97d3aa9c14da0b136dfe83f850eea9a5f7470427", size = 229892 }, { url = "https://files.pythonhosted.org/packages/ec/57/56b9bcc3c9c6a792fcbaf139543cee77261f3651ca9da0c93f5c1221264b/python_dateutil-2.9.0.post0-py2.py3-none-any.whl", hash = "sha256:a8b2bc7bffae282281c8140a97d3aa9c14da0b136dfe83f850eea9a5f7470427", size = 229892 },
] ]
[[package]]
name = "python-dotenv"
version = "1.1.0"
source = { registry = "https://pypi.org/simple" }
sdist = { url = "https://files.pythonhosted.org/packages/88/2c/7bb1416c5620485aa793f2de31d3df393d3686aa8a8506d11e10e13c5baf/python_dotenv-1.1.0.tar.gz", hash = "sha256:41f90bc6f5f177fb41f53e87666db362025010eb28f60a01c9143bfa33a2b2d5", size = 39920 }
wheels = [
{ url = "https://files.pythonhosted.org/packages/1e/18/98a99ad95133c6a6e2005fe89faedf294a748bd5dc803008059409ac9b1e/python_dotenv-1.1.0-py3-none-any.whl", hash = "sha256:d7c01d9e2293916c18baf562d95698754b0dbbb5e74d457c45d4f6561fb9d55d", size = 20256 },
]
[[package]] [[package]]
name = "reactivex" name = "reactivex"
version = "4.0.4" version = "4.0.4"
......
...@@ -29,7 +29,7 @@ class InfluxDBHelper: ...@@ -29,7 +29,7 @@ class InfluxDBHelper:
''' '''
query = f''' query = f'''
from(bucket: "{self.bucket}") from(bucket: "{self.bucket}")
|> range(start: -1h) |> range(start: -20d)
|> filter(fn: (r) => r["_measurement"] == "sensor_data") |> filter(fn: (r) => r["_measurement"] == "sensor_data")
''' '''
return self.query_api.query(org=self.org, query=query) return self.query_api.query(org=self.org, query=query)
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment