pyflink_events_generation Use local docker container for postgres Connect dev aws account with kinesis input-stream run >>> python datagen/datageneration.py >>> python main.py