accraze/stream-processor repository overview

⁠stream-processor

This container can process a stream of events using Celery and RabbitMQ. You will need to have RabbitMQ running in order to use this.

More info at homepage: https://github.com/accraze/stream-processor⁠

⁠Environment Variables

• AMQP_URI broker url
• PROCESSOR_EVENT_FILE path to sampled events file for testing.
• PROCESSOR_RESULTS_OUTFILE: where to store results file.

⁠Testing

You can run tests as follows:

docker exec -it stream-processor_worker_1 sh -c "python -m pytest --disable-pytest-warnings"