diff --git a/backend/app/influxdb_service.py b/backend/app/influxdb_service.py index fa31778f42e4fdc1735939c07aa53d448337514c..fb766e6f0548e1cc7284883ce1f26487576dc5e5 100644 --- a/backend/app/influxdb_service.py +++ b/backend/app/influxdb_service.py @@ -11,4 +11,8 @@ client = InfluxDBHelper( 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 diff --git a/backend/pyproject.toml b/backend/pyproject.toml index 356ccde0f82bc4edc77fe7043a31aaeff46db714..20d648f6b9103fbfc716072298e184ebc1babc7b 100644 --- a/backend/pyproject.toml +++ b/backend/pyproject.toml @@ -18,7 +18,8 @@ requires-python = ">=3.12" dependencies = [ "django>=5.2", "django-cors-headers>=4.7.0", - "influxdb-client>=1.40" + "influxdb-client>=1.40", + "python-dotenv", ] [dependency-groups] diff --git a/backend/uv.lock b/backend/uv.lock index bb5eac9050ed029ae4ff5fce08ba0f45b49c48a9..14bce673b74992908e4d1d848ac0047eb7ee25b7 100644 --- a/backend/uv.lock +++ b/backend/uv.lock @@ -19,9 +19,10 @@ dependencies = [ { name = "django" }, { name = "django-cors-headers" }, { name = "influxdb-client" }, + { name = "python-dotenv" }, ] -[package.optional-dependencies] +[package.dev-dependencies] dev = [ { name = "ruff" }, ] @@ -31,9 +32,11 @@ requires-dist = [ { name = "django", specifier = ">=5.2" }, { name = "django-cors-headers", specifier = ">=4.7.0" }, { 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]] name = "certifi" @@ -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 }, ] +[[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]] name = "reactivex" version = "4.0.4" diff --git a/utils/influx.py b/utils/influx.py index 55aca620dfbf0c399e943b5a317aebae59220549..963f5e747c83c325f6bb83d8c9dd6eed5bb125e7 100644 --- a/utils/influx.py +++ b/utils/influx.py @@ -29,7 +29,7 @@ class InfluxDBHelper: ''' query = f''' from(bucket: "{self.bucket}") - |> range(start: -1h) + |> range(start: -20d) |> filter(fn: (r) => r["_measurement"] == "sensor_data") ''' return self.query_api.query(org=self.org, query=query)