This nodestream project defines ingestion for the LDBC Financial Benchmark (LDBC FINBENCH). Learn more here: https://ldbcouncil.org/benchmarks/finbench/
To get started, first install the required dependencies:
poetry install
Note that this project uses poetry for dependency management. If you don't have poetry installed, you can install it following the instructions here.
If you don't want to keep typing poetry run
before every command, you can run the following command to enter a shell with the correct environment:
poetry shell
The samples below assume you are in a poetry shell.
It is important to run a migration to prepare your database before ingesting any data. To run a migration against your database run the following command: This will run the migration against the aura-db target, which is defind in the nodestream.yaml file
nodestream migrations run -t aura-db
To run a pipeline locally, use the following command:
nodestream run $PIPELINE_NAME
To run all of the pipelines in this project, use the following command: This will run all the pipelines, and send them to the target aura-db, which is defined in the nodestream.yaml file
nodestream run -t aura-db
To run tests, use the following command:
pytest