The basic idea is that you have a source and a target and a mapping in between and a catalog that holds all the information.
You can find simple exmaples here: python3 sandbox.py
First try to use static typing in python. Further more this is a playground to glue different components together (to name a few: load a csv, convert it into events, put it on queue and do some stream processing on it)...
python3 ./runner.py -p /tmp -c ./resources/catalog_auszug.json -s kontoauszug
make docker
docker run -v DIRECTORY_TO_OBSERVER:watchdog --net=host uploadio:0.0.1
Run all tests
make test
If you just want to test a specific tests, do as follows:
export PYTHONPATH=`pwd`
pytest -s test/sources/test_transformation.py::test_filter_on_df uploadio/