From 59e0d08a32149ec959296d4c23945b07d75262cb Mon Sep 17 00:00:00 2001 From: Andreas Motl Date: Sat, 21 Dec 2024 16:11:40 +0100 Subject: [PATCH] CTK/InfluxDB: Demonstrate loading ILP data --- application/cratedb-toolkit/requirements.txt | 3 ++- application/cratedb-toolkit/test_io.py | 6 +++--- 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/application/cratedb-toolkit/requirements.txt b/application/cratedb-toolkit/requirements.txt index 6e8daa3c..ff901609 100644 --- a/application/cratedb-toolkit/requirements.txt +++ b/application/cratedb-toolkit/requirements.txt @@ -1,2 +1,3 @@ crate>=1.0.0.dev2 -cratedb-toolkit[influxdb,mongodb]>=0.0.29 +#cratedb-toolkit[influxdb,mongodb]>=0.0.29 +cratedb-toolkit[influxdb,mongodb] @ git+https://github.com/crate/cratedb-toolkit.git@influxdb-ilp diff --git a/application/cratedb-toolkit/test_io.py b/application/cratedb-toolkit/test_io.py index dbe57303..756cb612 100644 --- a/application/cratedb-toolkit/test_io.py +++ b/application/cratedb-toolkit/test_io.py @@ -86,9 +86,9 @@ def test_ctk_load_table_influxdb_lp(drop_testing_tables): # Invoke data transfer. command = f""" -influxio copy \ - {influxdb_lp_url} \ - "crate://localhost:4200/from-influxdb/air-sensor-data" + ctk load table \ + "{influxdb_lp_url}" \ + --cratedb-sqlalchemy-url="crate://localhost:4200/from-influxdb/air-sensor-data" """ print(f"Invoking CTK: {command}", file=sys.stderr) subprocess.check_call(shlex.split(command))